Struct RecordDecoder

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

Decodes avro encoded data into [RecordBatch]

Fields

schema: SchemaRef

fields: Vec<Decoder>

use_utf8view: bool

strict_mode: bool

Implementations

impl RecordDecoder

pub(crate) fn new(data_type: &AvroDataType) -> Self

Creates a new RecordDecoderBuilder for configuring a RecordDecoder.

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

Create a new RecordDecoder from the provided AvroDataType with default options

pub(crate) fn try_new_with_options( data_type: &AvroDataType, use_utf8view: bool, strict_mode: bool, ) -> Result<Self, ArrowError>

Creates 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.

Arguments

• data_type - The Avro data type to decode.
• use_utf8view - A flag indicating whether to use Utf8View for string types.
• strict_mode - A flag to enable strict decoding, returning an error if the data does not conform to the schema.

Errors

This function will return an error if the provided data_type is not a Record.

pub(crate) fn schema(&self) -> &SchemaRef

Returns the decoder’s SchemaRef

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

Decode count records from buf

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

Flush the decoded records into a [RecordBatch]

Trait Implementations

impl Debug for RecordDecoder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.