Struct TypedTripletIter

pub struct TypedTripletIter<T: DataType> {
    reader: ColumnReaderImpl<T>,
    column_descr: ColumnDescPtr,
    batch_size: usize,
    max_def_level: i16,
    max_rep_level: i16,
    values: Vec<T::T>,
    def_levels: Option<Vec<i16>>,
    rep_levels: Option<Vec<i16>>,
    curr_triplet_index: usize,
    triplets_left: usize,
    has_next: bool,
}

Internal typed triplet iterator as a wrapper for column reader (primitive leaf column), provides per-element access.

Fields

reader: ColumnReaderImpl<T>

column_descr: ColumnDescPtr

batch_size: usize

max_def_level: i16

max_rep_level: i16

values: Vec<T::T>

def_levels: Option<Vec<i16>>

rep_levels: Option<Vec<i16>>

curr_triplet_index: usize

triplets_left: usize

has_next: bool

Implementations

impl<T: DataType> TypedTripletIter<T>

fn new( descr: ColumnDescPtr, batch_size: usize, column_reader: ColumnReader, ) -> Self

Creates new typed triplet iterator based on provided column reader. Use batch size to specify the amount of values to buffer from column reader.

pub fn column_descr(&self) -> &ColumnDescPtr

Returns column descriptor reference for the current typed triplet iterator.

fn max_def_level(&self) -> i16

Returns maximum definition level for the triplet iterator (leaf column).

fn max_rep_level(&self) -> i16

Returns maximum repetition level for the triplet iterator (leaf column).

fn current_value(&self) -> &T::T

Returns current value. Method does not advance the iterator, therefore can be called multiple times.

fn current_def_level(&self) -> i16

Returns current definition level. If field is required, then maximum definition level is returned.

fn current_rep_level(&self) -> i16

Returns current repetition level. If field is required, then maximum repetition level is returned.

fn has_next(&self) -> bool

Quick check if iterator has more values/levels to read. It is updated as a result of read_next method, so they are synchronized.

fn read_next(&mut self) -> Result<bool>

Advances to the next triplet. Returns true, if there are more records to read, false there are no records left.