Struct Decoder

pub struct Decoder {
    record_decoder: RecordDecoder,
    batch_size: usize,
    decoded_rows: usize,
}

A low-level interface for decoding Avro-encoded bytes into Arrow RecordBatch.

Fields

record_decoder: RecordDecoder

batch_size: usize

decoded_rows: usize

Implementations

impl Decoder

fn new(record_decoder: RecordDecoder, batch_size: usize) -> Self

pub fn schema(&self) -> SchemaRef

Return the Arrow schema for the rows decoded by this decoder

pub fn batch_size(&self) -> usize

Return the configured maximum number of rows per batch

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

Feed data into the decoder row by row until we either:

• consume all bytes in data, or
• reach batch_size decoded rows.

Returns the number of bytes consumed.

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

Produce a RecordBatch if at least one row is fully decoded, returning Ok(None) if no new rows are available.

pub fn capacity(&self) -> usize

Returns the number of rows that can be added to this decoder before it is full.

pub fn batch_is_full(&self) -> bool

Returns true if the decoder has reached its capacity for the current batch.

Trait Implementations

impl Debug for Decoder

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

Formats the value using the given formatter.