Struct ArrayReader

struct ArrayReader<'a> {
    dictionaries_by_id: &'a HashMap<i64, ArrayRef>,
    compression: Option<CompressionCodec>,
    version: MetadataVersion,
    data: &'a Buffer,
    nodes: VectorIter<'a, FieldNode>,
    buffers: VectorIter<'a, Buffer>,
}

State for decoding arrays from an encoded [RecordBatch]

Fields

dictionaries_by_id: &'a HashMap<i64, ArrayRef>

Decoded dictionaries indexed by dictionary id

compression: Option<CompressionCodec>

Optional compression codec

version: MetadataVersion

The format version

data: &'a Buffer

The raw data buffer

nodes: VectorIter<'a, FieldNode>

The fields comprising this array

buffers: VectorIter<'a, Buffer>

The buffers comprising this array

Implementations

impl<'a> ArrayReader<'a>

fn next_buffer(&mut self) -> Result<Buffer, ArrowError>

fn skip_buffer(&mut self)

fn next_node(&mut self, field: &Field) -> Result<&'a FieldNode, ArrowError>

fn skip_field( &mut self, field: &Field, variadic_count: &mut VecDeque<i64>, ) -> Result<(), ArrowError>