Struct parquet::arrow::arrow_array_reader::ArrowArrayReader

pub struct ArrowArrayReader<'a, C: ArrayConverter + 'a> { /* fields omitted */ }

Implementations

impl<'a, C: ArrayConverter + 'a> ArrowArrayReader<'a, C>

pub fn try_new<P: PageIterator + 'a>(
    column_chunk_iterator: P,
    column_desc: ColumnDescPtr,
    array_converter: C,
    arrow_type: Option<ArrowType>
) -> Result<Self>

Trait Implementations

impl<C: ArrayConverter> ArrayReader for ArrowArrayReader<'static, C>

fn as_any(&self) -> &dyn Any

fn get_data_type(&self) -> &ArrowType

Returns the arrow type of this array reader.

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

Reads at most batch_size records into an arrow array and return it.

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.