Struct parquet::arrow::array_reader::PrimitiveArrayReader

pub struct PrimitiveArrayReader<T: DataType> { /* fields omitted */ }

Primitive array readers are leaves of array reader tree. They accept page iterator and read them into primitive arrays.

Implementations

impl<T: DataType> PrimitiveArrayReader<T>

pub fn new(
    pages: Box<dyn PageIterator>,
    column_desc: ColumnDescPtr,
    arrow_type: Option<ArrowType>
) -> Result<Self>

Construct primitive array reader.

Trait Implementations

impl<T: DataType> ArrayReader for PrimitiveArrayReader<T>

Implementation of primitive array reader.

fn get_data_type(&self) -> &ArrowType

Returns data type of primitive array.

fn next_batch(&mut self, batch_size: usize) -> Result<ArrayRef>

Reads at most batch_size records into array.

fn as_any(&self) -> &dyn Any

fn get_def_levels(&self) -> Option<&[i16]>

Returns the definition levels of data from last call of next_batch. The result is used by parent array reader to calculate its own definition levels and repetition levels, so that its parent can calculate null bitmap.

fn get_rep_levels(&self) -> Option<&[i16]>

Return the repetition levels of data from last call of next_batch. The result is used by parent array reader to calculate its own definition levels and repetition levels, so that its parent can calculate null bitmap.