Struct RecordDecoder

pub struct RecordDecoder {
    schema: SchemaRef,
    fields: Vec<Decoder>,
    use_utf8view: bool,
}

Decodes avro encoded data into [RecordBatch]

Fields

schema: SchemaRef

fields: Vec<Decoder>

use_utf8view: bool

Implementations

impl RecordDecoder

pub fn try_new(data_type: &AvroDataType) -> Result<Self, ArrowError>

Create a new RecordDecoder from the provided AvroDataType with default options

pub fn try_new_with_options( data_type: &AvroDataType, options: ReadOptions, ) -> Result<Self, ArrowError>

Create a new RecordDecoder from the provided AvroDataType with additional options

This method allows you to customize how the Avro data is decoded into Arrow arrays.

Parameters

• data_type - The Avro data type to decode
• options - Configuration options for decoding

pub fn schema(&self) -> &SchemaRef

pub fn decode(&mut self, buf: &[u8], count: usize) -> Result<usize, ArrowError>

Decode count records from buf

pub fn flush(&mut self) -> Result<RecordBatch, ArrowError>

Flush the decoded records into a [RecordBatch]