lance-file 0.21.0

Utilities for the Lance file format
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

// SPDX-License-Identifier: Apache-2.0
// SPDX-FileCopyrightText: Copyright The Lance Authors

use futures::{future::BoxFuture, FutureExt};
use lance_encoding::EncodingsIo;
use lance_io::scheduler::FileScheduler;

#[derive(Debug)]
pub struct LanceEncodingsIo(pub FileScheduler);

impl EncodingsIo for LanceEncodingsIo {
    fn submit_request(
        &self,
        range: Vec<std::ops::Range<u64>>,
        priority: u64,
    ) -> BoxFuture<'static, lance_core::Result<Vec<bytes::Bytes>>> {
        self.0.submit_request(range, priority).boxed()
    }
}