Struct PrimitiveFieldScheduler

pub struct PrimitiveFieldScheduler { /* private fields */ }

A field scheduler for primitive fields

This maps to exactly one column and it assumes that the top-level encoding of each page is “basic”. The basic encoding decodes into an optional buffer of validity and a fixed-width buffer of values which is exactly what we need to create a primitive array.

Note: we consider booleans and fixed-size-lists of primitive types to be primitive types. This is slightly different than arrow-rs’s definition

Implementations

impl PrimitiveFieldScheduler

pub fn new( column_index: u32, data_type: DataType, pages: Arc<[PageInfo]>, buffers: ColumnBuffers<'_, '_>, should_validate: bool, ) -> Self

Trait Implementations

impl Debug for PrimitiveFieldScheduler

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

Formats the value using the given formatter.

impl FieldScheduler for PrimitiveFieldScheduler

fn num_rows(&self) -> u64

The number of rows in this field

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

Called at the beginning of scheduling to initialize the scheduler