Struct lance_encoding_datafusion::zone::ZoneMapsFieldScheduler

pub struct ZoneMapsFieldScheduler { /* private fields */ }

A top level scheduler that refines the requested range based on pushdown filtering with zone maps

Implementations

impl ZoneMapsFieldScheduler

pub fn new( inner: Arc<dyn FieldScheduler>, schema: Arc<Schema>, pushdown_buffers: Vec<UnloadedPushdown>, rows_per_zone: u32, num_rows: u64, ) -> Self

pub fn initialize<'a>( &'a mut self, io: &dyn EncodingsIo, ) -> BoxFuture<'a, Result<()>>

Load the zone maps from the file

TODO: only load zone maps for columns used in the filter

Trait Implementations

impl Debug for ZoneMapsFieldScheduler

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

Formats the value using the given formatter.

impl FieldScheduler for ZoneMapsFieldScheduler

fn schedule_ranges<'a>( &'a self, ranges: &[Range<u64>], filter: &FilterExpression, ) -> Result<Box<dyn SchedulingJob + 'a>>

Schedules I/O for the requested portions of the field.

fn num_rows(&self) -> u64

The number of rows in this field