Struct StructuralStructScheduler

pub struct StructuralStructScheduler { /* private fields */ }

A scheduler for structs

The implementation is actually a bit more tricky than one might initially think. We can’t just go through and schedule each column one after the other. This would mean our decode can’t start until nearly all the data has arrived (since we need data from each column to yield a batch)

Instead, we schedule in row-major fashion

Note: this scheduler is the starting point for all decoding. This is because we treat the top-level record batch as a non-nullable struct.

Implementations

impl StructuralStructScheduler

pub fn new( children: Vec<Box<dyn StructuralFieldScheduler>>, child_fields: Fields, ) -> Self

Trait Implementations

impl Debug for StructuralStructScheduler

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

Formats the value using the given formatter.

impl StructuralFieldScheduler for StructuralStructScheduler

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

fn initialize<'a>( &'a mut self, filter: &'a FilterExpression, context: &'a SchedulerContext, ) -> BoxFuture<'a, Result<()>>