Struct Planner 

struct Planner {
    frontier: RowGroupFrontier,
    active_row_group: Option<NextRowGroup>,
    columns: Arc<StageColumns>,
    next_row: u64,
    current: Option<RowGroupRanges>,
    done: bool,
}

The state of a ScanPlan that is not empty.

Fields

frontier: RowGroupFrontier

The decoder’s row-group queue, selections and offset/limit budget, as they were when the plan was made.

active_row_group: Option<NextRowGroup>

The row group that the decoder was fetching when the plan was made. It is planned first.

columns: Arc<StageColumns>

The decoder’s projection, predicates and batch size.

next_row: u64

Planned rows before the next row group.

current: Option<RowGroupRanges>

The row group being planned, if any.

done: bool

Whether planning has ended.

Implementations

impl Planner

fn plan_next_row_group(&mut self) -> Result<bool, ParquetError>

Start planning the next row group the decoder will read.

Returns Ok(false) when no row group remains. A row group that the offset/limit budget removes is planned with no ranges.

impl Planner

fn next(&mut self) -> Option<PlannedRange>

Trait Implementations

impl Clone for Planner

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Planner

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

Formats the value using the given formatter.