Struct 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: HashMap<u32, UnloadedPushdown>, rows_per_zone: u32, num_rows: u64, ) -> Self

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 initialize<'a>( &'a self, filter: &'a FilterExpression, context: &'a SchedulerContext, ) -> BoxFuture<'a, Result<()>>

Called at the beginning of scheduling to initialize the scheduler

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