Struct LanceEncodingsIo 

pub struct LanceEncodingsIo { /* private fields */ }

Implementations

impl LanceEncodingsIo

pub fn new(scheduler: FileScheduler) -> Self

pub fn with_read_chunk_size(self, read_chunk_size: u64) -> Self

Trait Implementations

impl Debug for LanceEncodingsIo

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EncodingsIo for LanceEncodingsIo

fn with_bypass_backpressure(&self) -> Option<Arc<dyn EncodingsIo>>

Returns a version of this I/O service that bypasses backpressure for all requests.

fn with_io_stats( &self, stats: Arc<dyn IoStatsRecorder>, ) -> Option<Arc<dyn EncodingsIo>>

Returns a version of this I/O service that additionally records the I/O it performs into stats, on top of any global accounting. This is the seam used to measure exact per-scope (e.g. per-query) I/O without re-opening files: wrap a reader’s I/O service, perform the reads, then inspect the recorder.

fn submit_request( &self, ranges: Vec<Range<u64>>, priority: u64, ) -> BoxFuture<'static, Result<Vec<Bytes>>>

Submit an I/O request

fn submit_single( &self, range: Range<u64>, priority: u64, ) -> Pin<Box<dyn Future<Output = Result<Bytes, Error>> + Send>>

Submit an I/O request with a single range