Enum TripletIter

pub enum TripletIter {
    BoolTripletIter(TypedTripletIter<BoolType>),
    Int32TripletIter(TypedTripletIter<Int32Type>),
    Int64TripletIter(TypedTripletIter<Int64Type>),
    Int96TripletIter(TypedTripletIter<Int96Type>),
    FloatTripletIter(TypedTripletIter<FloatType>),
    DoubleTripletIter(TypedTripletIter<DoubleType>),
    ByteArrayTripletIter(TypedTripletIter<ByteArrayType>),
    FixedLenByteArrayTripletIter(TypedTripletIter<FixedLenByteArrayType>),
}

High level API wrapper on column reader. Provides per-element access for each primitive column.

Variants

BoolTripletIter(TypedTripletIter<BoolType>)

Int32TripletIter(TypedTripletIter<Int32Type>)

Int64TripletIter(TypedTripletIter<Int64Type>)

Int96TripletIter(TypedTripletIter<Int96Type>)

FloatTripletIter(TypedTripletIter<FloatType>)

DoubleTripletIter(TypedTripletIter<DoubleType>)

ByteArrayTripletIter(TypedTripletIter<ByteArrayType>)

FixedLenByteArrayTripletIter(TypedTripletIter<FixedLenByteArrayType>)

Implementations

impl TripletIter

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

Creates new triplet for column reader

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

Invokes underlying typed triplet iterator to buffer current value. Should be called once - either before is_null or current_value.

pub fn has_next(&self) -> bool

Provides check on values/levels left without invoking the underlying typed triplet iterator. Returns true if more values/levels exist, false otherwise. It is always in sync with read_next method.

pub fn current_def_level(&self) -> i16

Returns current definition level for a leaf triplet iterator

pub fn max_def_level(&self) -> i16

Returns max definition level for a leaf triplet iterator

pub fn current_rep_level(&self) -> i16

Returns current repetition level for a leaf triplet iterator

pub fn max_rep_level(&self) -> i16

Returns max repetition level for a leaf triplet iterator

pub fn is_null(&self) -> bool

Returns true, if current value is null. Based on the fact that for non-null value current definition level equals to max definition level.

pub fn current_value(&self) -> Result<Field>

Updates non-null value for current row.