Struct RecordDecoder

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

Decodes avro encoded data into [RecordBatch]

Fields

schema: SchemaRef

fields: Vec<Decoder>

Implementations

impl RecordDecoder

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

Create a new RecordDecoder from the provided AvroDataType

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]