Struct RecordEncoder 

pub(crate) struct RecordEncoder {
    columns: Vec<FieldBinding>,
    prefix: Option<Prefix>,
}

A pre-computed plan for encoding a RecordBatch to Avro.

Derived from an Avro schema and an Arrow schema. It maps top-level Avro fields to Arrow columns and contains a nested encoding plan for each column.

Fields

columns: Vec<FieldBinding>

prefix: Option<Prefix>

Optional pre-built, variable-length prefix written before each record.

Implementations

impl RecordEncoder

fn prepare_for_batch<'a>( &'a self, batch: &'a RecordBatch, ) -> Result<Vec<FieldEncoder<'a>>, AvroError>

pub(crate) fn encode<W: Write>( &self, out: &mut W, batch: &RecordBatch, ) -> Result<(), AvroError>

Encode a RecordBatch using this encoder plan.

Tip: Wrap out in a std::io::BufWriter to reduce the overhead of many small writes.

pub(crate) fn encode_rows( &self, batch: &RecordBatch, row_capacity: usize, out: &mut BytesMut, offsets: &mut Vec<usize>, ) -> Result<(), AvroError>

Encode rows into a single contiguous BytesMut and append row-end offsets.

Invariants

• offsets must be non-empty and seeded with 0 at index 0.
• offsets.last() must equal out.len() on entry.
• On success, exactly batch.num_rows() additional offsets are pushed, and offsets.last() equals the new out.len().

Trait Implementations

impl Clone for RecordEncoder

fn clone(&self) -> RecordEncoder

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RecordEncoder

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

Formats the value using the given formatter.