Enum RowGroupDecoderState 

enum RowGroupDecoderState {
    Start {
        row_group_info: RowGroupInfo,
    },
    Filters {
        row_group_info: RowGroupInfo,
        column_chunks: Option<Vec<Option<Arc<ColumnChunkData>>>>,
        filter_info: FilterInfo,
    },
    WaitingOnFilterData {
        row_group_info: RowGroupInfo,
        filter_info: FilterInfo,
        data_request: DataRequest,
    },
    StartData {
        row_group_info: RowGroupInfo,
        column_chunks: Option<Vec<Option<Arc<ColumnChunkData>>>>,
        cache_info: Option<CacheInfo>,
    },
    WaitingOnData {
        row_group_info: RowGroupInfo,
        data_request: DataRequest,
        cache_info: Option<CacheInfo>,
    },
    Finished,
}

This is the inner state machine for reading a single row group.

Variants

Start

Fields

row_group_info: RowGroupInfo

Filters

Planning filters, but haven’t yet requested data to evaluate them

Fields

row_group_info: RowGroupInfo

column_chunks: Option<Vec<Option<Arc<ColumnChunkData>>>>

Any previously read column chunk data from prior filters

filter_info: FilterInfo

WaitingOnFilterData

Needs data to evaluate current filter

Fields

row_group_info: RowGroupInfo

filter_info: FilterInfo

data_request: DataRequest

StartData

Know what data to actually read, after all predicates

Fields

row_group_info: RowGroupInfo

column_chunks: Option<Vec<Option<Arc<ColumnChunkData>>>>

Any previously read column chunk data from the filtering phase

cache_info: Option<CacheInfo>

Any cached filter results

WaitingOnData

Needs data to proceed with reading the output

Fields

row_group_info: RowGroupInfo

data_request: DataRequest

cache_info: Option<CacheInfo>

Any cached filter results

Finished

Finished (or not yet started) reading this group

Trait Implementations

impl Debug for RowGroupDecoderState

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

Formats the value using the given formatter.