Struct QueuedRowGroups 

struct QueuedRowGroups {
    queue: Queue,
    counts: HashMap<usize, usize>,
}

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

Fields

queue: Queue

counts: HashMap<usize, usize>

The number of times each row group is in queue, so that Self::contains does not scan the queue.

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 row_groups(&self) -> impl Iterator<Item = usize> + '_

The row groups in the queue, in no specific order and without duplicates.

fn contains(&self, row_group_idx: usize) -> bool

Returns true if row_group_idx is in the queue.

fn len(&self) -> usize

fn clear(&mut self)

fn global_selection_is_exhausted(&self) -> bool

See Queue::global_selection_is_exhausted.

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) -> Self

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.