Struct lance_encoding::encodings::logical::primitive::PrimitivePageScheduler

pub struct PrimitivePageScheduler { /* private fields */ }

A page scheduler for primitive fields

This maps to exactly one physical page and it assumes that the top-level encoding of the 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 PrimitivePageScheduler

pub fn new( data_type: DataType, page: Arc<PageInfo>, buffers: ColumnBuffers<'_, '_> ) -> Self

Trait Implementations

impl Debug for PrimitivePageScheduler

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

Formats the value using the given formatter.

impl LogicalPageScheduler for PrimitivePageScheduler

fn num_rows(&self) -> u32

The number of rows covered by this page

fn schedule_ranges( &self, ranges: &[Range<u32>], context: &mut SchedulerContext, top_level_row: u64 ) -> Result<()>

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

fn schedule_take( &self, indices: &[u32], context: &mut SchedulerContext, top_level_row: u64 ) -> Result<()>

Schedules I/O for the requested rows (identified by row offsets from start of page) TODO: implement this using schedule_ranges