Struct ScanPlanBuilder 

pub(crate) struct ScanPlanBuilder {
    frontier: RowGroupFrontier,
    active_row_group: Option<NextRowGroup>,
    columns: StageColumns,
}

Builds a ScanPlan from a decoder’s row-group frontier and the columns each decoding stage reads.

Fields

frontier: RowGroupFrontier

active_row_group: Option<NextRowGroup>

columns: StageColumns

Implementations

impl ScanPlanBuilder

pub(crate) fn new( frontier: RowGroupFrontier, batch_size: usize, stages: Arc<StageSchedule>, ) -> Self

Plan the row groups in frontier, decoding in batches of batch_size rows with the decoding stages stages.

pub(crate) fn with_active_row_group( self, active_row_group: Option<NextRowGroup>, ) -> Self

Plan active_row_group first: the row group that the decoder is fetching, which the frontier has already handed over.

pub(crate) fn build(self) -> ScanPlan

Trait Implementations

impl Debug for ScanPlanBuilder

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

Formats the value using the given formatter.