Struct WriterBuilder 

pub struct WriterBuilder {
    schema: Schema,
    codec: Option<CompressionCodec>,
    row_capacity: Option<usize>,
    capacity: usize,
    fingerprint_strategy: Option<FingerprintStrategy>,
}

Builder to configure and create a Writer.

Fields

schema: Schema

codec: Option<CompressionCodec>

row_capacity: Option<usize>

capacity: usize

fingerprint_strategy: Option<FingerprintStrategy>

Implementations

impl WriterBuilder

pub fn new(schema: Schema) -> Self

Create a new builder with default settings.

The Avro schema used for writing is determined as follows:

1. If the Arrow schema metadata contains avro::schema (see SCHEMA_METADATA_KEY), that JSON is used verbatim.
2. Otherwise, the Arrow schema is converted to an Avro record schema.

pub fn with_fingerprint_strategy(self, strategy: FingerprintStrategy) -> Self

Set the fingerprinting strategy for the stream writer. This determines the per-record prefix format.

pub fn with_compression(self, codec: Option<CompressionCodec>) -> Self

Change the compression codec.

pub fn with_capacity(self, capacity: usize) -> Self

Sets the expected capacity (in bytes) for internal buffers.

This is used as a hint to pre-allocate staging buffers for writing.

pub fn with_row_capacity(self, capacity: usize) -> Self

Sets the expected byte size for each encoded row.

This setting affects Encoder created via build_encoder. It is used as a hint to reduce reallocations when the typical encoded row size is known.

fn prepare_encoder<F: AvroFormat>( &self, ) -> Result<(Arc<Schema>, RecordEncoder), AvroError>

pub fn build_encoder<F: AvroFormat>(self) -> Result<Encoder, AvroError>

Build a new Encoder for the given AvroFormat.

Encoder only supports stream formats (no OCF sync markers). Attempting to build an encoder with an OCF format (e.g. AvroOcfFormat) will return an error.

pub fn build<W, F>(self, writer: W) -> Result<Writer<W, F>, AvroError>

where W: Write, F: AvroFormat,

Build a new Writer with the specified AvroFormat and builder options.

Trait Implementations

impl Clone for WriterBuilder

fn clone(&self) -> WriterBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriterBuilder

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

Formats the value using the given formatter.