Enum Queue 

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

The queue of QueuedRowGroups.

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 Queue

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_group_indices(&self) -> Vec<usize>

The queued row group indexes, in order.

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 Queue

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 Queue

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

Formats the value using the given formatter.