Enum QueuedRowGroups 

enum QueuedRowGroups {
    Global {
        row_groups: VecDeque<usize>,
        selection: Option<RowSelection>,
    },
    PerRowGroup(VecDeque<RowGroupSelection>),
}

Row groups and selections that have not yet been handed to the row-group reader builder.

Variants

Global

One selection cursor spans all queued row groups.

Fields

row_groups: VecDeque<usize>

selection: Option<RowSelection>

PerRowGroup(VecDeque<RowGroupSelection>)

Selections are already relative to their respective row groups.

Implementations

impl QueuedRowGroups

fn try_new( parquet_metadata: &ParquetMetaData, row_group_plan: RowGroupPlan, ) -> Result<Self, ParquetError>

Validate and queue a row-group plan for parquet_metadata.

fn into_plan(self) -> RowGroupPlan

Convert the remaining queue back into a builder configuration.

fn front(&self) -> Option<usize>

fn len(&self) -> usize

fn clear(&mut self)

fn global_selection_is_exhausted(&self) -> bool

Returns true when a shared global selection has no selected rows left. Per-row-group selections are independent and are drained one at a time.

fn pop_front_selection(&mut self, row_count: usize) -> Option<RowSelection>

Remove the front row group and return its local selection.

Trait Implementations

impl Clone for QueuedRowGroups

fn clone(&self) -> QueuedRowGroups

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueuedRowGroups

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

Formats the value using the given formatter.