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>>, ArrowError>

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

Encode a RecordBatch using this encoder plan.

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

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.