Struct RowGroupFrontier 

struct RowGroupFrontier {
    parquet_metadata: Arc<ParquetMetaData>,
    row_groups: VecDeque<usize>,
    selection: Option<RowSelection>,
    budget: RowBudget,
    has_predicates: bool,
}

Fields

parquet_metadata: Arc<ParquetMetaData>

Metadata used to resolve row counts for queued row groups.

row_groups: VecDeque<usize>

Row group indices not yet handed to the builder.

selection: Option<RowSelection>

Cross-row-group cursor for the optional global row selection.

budget: RowBudget

Offset/limit budget before the next readable row group is planned.

has_predicates: bool

If predicates are present, row groups with selected rows must be read so the predicate can decide whether they are actually needed.

Implementations

impl RowGroupFrontier

fn new( parquet_metadata: Arc<ParquetMetaData>, row_groups: Vec<usize>, selection: Option<RowSelection>, budget: RowBudget, has_predicates: bool, ) -> Self

fn row_group_num_rows( &self, row_group_idx: usize, ) -> Result<usize, ParquetError>

fn update_budget_after_row_group(&mut self, budget: RowBudget)

fn clear_remaining(&mut self)

fn plan_selected_row_group( &self, next_row_group: NextRowGroup, selected_rows: usize, ) -> QueuedRowGroupDecision

Plan whether a selected row group should be read or skipped.

Selection-only skips are handled before this method is called. This method applies the remaining offset/limit budget and predicate conservatism.

fn next_readable_row_group( &mut self, ) -> Result<Option<NextRowGroup>, ParquetError>

Advance queued row groups until one should be handed to the builder.

Trait Implementations

impl Debug for RowGroupFrontier

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

Formats the value using the given formatter.