Module encoder 

Encodes RecordBatch into the Avro binary format. Avro Encoder for Arrow types.

Re-exports

use crate::codec::AvroDataType; 🔒

use crate::codec::AvroField; 🔒

use crate::codec::Codec; 🔒

use crate::errors::AvroError; 🔒

use crate::schema::Fingerprint; 🔒

use crate::schema::Nullability; 🔒

use crate::schema::Prefix; 🔒

use arrow_array::Float16Array; 🔒

use arrow_array::cast::AsArray; 🔒

use arrow_array::types::ArrowPrimitiveType; 🔒

use arrow_array::types::Date32Type; 🔒

use arrow_array::types::Date64Type; 🔒

use arrow_array::types::DurationMicrosecondType; 🔒

use arrow_array::types::DurationMillisecondType; 🔒

use arrow_array::types::DurationNanosecondType; 🔒

use arrow_array::types::DurationSecondType; 🔒

use arrow_array::types::Float16Type; 🔒

use arrow_array::types::Float32Type; 🔒

use arrow_array::types::Float64Type; 🔒

use arrow_array::types::Int8Type; 🔒

use arrow_array::types::Int16Type; 🔒

use arrow_array::types::Int32Type; 🔒

use arrow_array::types::Int64Type; 🔒

use arrow_array::types::IntervalDayTimeType; 🔒

use arrow_array::types::IntervalMonthDayNanoType; 🔒

use arrow_array::types::IntervalYearMonthType; 🔒

use arrow_array::types::RunEndIndexType; 🔒

use arrow_array::types::Time32MillisecondType; 🔒

use arrow_array::types::Time32SecondType; 🔒

use arrow_array::types::Time64MicrosecondType; 🔒

use arrow_array::types::Time64NanosecondType; 🔒

use arrow_array::types::TimestampMicrosecondType; 🔒

use arrow_array::types::TimestampMillisecondType; 🔒

use arrow_array::types::TimestampNanosecondType; 🔒

use arrow_array::types::TimestampSecondType; 🔒

use arrow_array::types::UInt8Type; 🔒

use arrow_array::types::UInt16Type; 🔒

use arrow_array::types::UInt32Type; 🔒

use arrow_array::types::UInt64Type; 🔒

use arrow_array::Array; 🔒

use arrow_array::BinaryViewArray; 🔒

use arrow_array::Decimal128Array; 🔒

use arrow_array::Decimal256Array; 🔒

use arrow_array::DictionaryArray; 🔒

use arrow_array::FixedSizeBinaryArray; 🔒

use arrow_array::FixedSizeListArray; 🔒

use arrow_array::GenericBinaryArray; 🔒

use arrow_array::GenericListArray; 🔒

use arrow_array::GenericListViewArray; 🔒

use arrow_array::GenericStringArray; 🔒

use arrow_array::LargeListArray; 🔒

use arrow_array::LargeListViewArray; 🔒

use arrow_array::ListArray; 🔒

use arrow_array::ListViewArray; 🔒

use arrow_array::MapArray; 🔒

use arrow_array::OffsetSizeTrait; 🔒

use arrow_array::PrimitiveArray; 🔒

use arrow_array::RecordBatch; 🔒

use arrow_array::RunArray; 🔒

use arrow_array::StringArray; 🔒

use arrow_array::StringViewArray; 🔒

use arrow_array::StructArray; 🔒

use arrow_array::UnionArray; 🔒

use arrow_array::Decimal32Array; 🔒

use arrow_array::Decimal64Array; 🔒

use arrow_buffer::ArrowNativeType; 🔒

use arrow_buffer::NullBuffer; 🔒

use arrow_schema::DataType; 🔒

use arrow_schema::Field; 🔒

use arrow_schema::IntervalUnit; 🔒

use arrow_schema::Schema as ArrowSchema; 🔒

use arrow_schema::TimeUnit; 🔒

use arrow_schema::UnionMode; 🔒

use bytes::BufMut; 🔒

use bytes::BytesMut; 🔒

use std::io::Write; 🔒

use std::sync::Arc; 🔒

use uuid::Uuid; 🔒

Macros

for_rows_with_prefix 🔒

Structs

BinaryEncoder 🔒

Unified binary encoder generic over offset size (i32/i64).

BinaryViewEncoder 🔒

BinaryView (byte view) encoder.

BooleanEncoder 🔒

DecimalEncoder 🔒

Generic Avro decimal encoder over Arrow decimal arrays.

DurationEncoder 🔒

Single generic encoder used for all three interval units. Writes Avro fixed(12) as three little-endian u32 values in one call.

DurationParts 🔒

EnumEncoder 🔒

Avro enum encoder for Arrow DictionaryArray<Int32, Utf8>.

F32Encoder 🔒

F64Encoder 🔒

FieldBinding 🔒

FieldEncoder 🔒

Arrow to Avro FieldEncoder:

FixedEncoder 🔒

Avro fixed encoder for Arrow FixedSizeBinaryArray. Spec: a fixed is encoded as exactly size bytes, with no length prefix.

FixedSizeListEncoder 🔒

FixedSizeList encoder.

Float16FixedEncoder 🔒

Float16 to Avro fixed(2) encoder (IEEE-754 little-endian bits)

Int8Encoder 🔒

Int8 to Avro int encoder (converts i8 to i32)

Int16Encoder 🔒

Int16 to Avro int encoder (converts i16 to i32)

IntEncoder 🔒

Generic Avro int encoder for primitive arrays with i32 native values.

IntervalDayTimeFixedEncoder 🔒

Interval(DayTime) to Avro fixed(8) encoder (little-endian i32 days + i32 milliseconds)

IntervalMonthDayNanoFixedEncoder 🔒

Interval(MonthDayNano) encoder for the Arrow-specific logical type arrow.interval-month-day-nano.

IntervalYearMonthFixedEncoder 🔒

Interval(YearMonth) to Avro fixed(4) encoder (little-endian i32 months)

ListEncoder 🔒

ListViewEncoder 🔒

ListView encoder using (offset, size) buffers.

LongEncoder 🔒

Generic Avro long encoder for primitive arrays with i64 native values.

MapEncoder 🔒

RecordEncoder 🔒

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

RecordEncoderBuilder 🔒

Builder for RecordEncoder write plan

RunEncodedEncoder 🔒

Generic encoder for Arrow RunArray<R>-based sites (run-end encoded). Follows the pattern used by other generic encoders (i.e., ListEncoder<O>), avoiding runtime branching on run-end width.

StructEncoder 🔒

Time32SecondsToMillisEncoder 🔒

Time32(Second) to Avro time-millis (int), via safe scaling by 1000

UInt8Encoder 🔒

UInt8 to Avro int encoder (converts u8 to i32)

UInt16Encoder 🔒

UInt16 to Avro int encoder (converts u16 to i32)

UInt32Encoder 🔒

UInt32 to Avro long encoder (converts u32 to i64)

UInt64FixedEncoder 🔒

UInt64 to Avro fixed(8) encoder (little-endian bytes)

UnionEncoder 🔒

Utf8GenericEncoder 🔒

Utf8ViewEncoder 🔒

StringView encoder.

UuidEncoder 🔒

Avro UUID logical type encoder: Arrow FixedSizeBinary(16) to Avro string (UUID). Spec: uuid is a logical type over string (RFC‑4122). We output hyphenated form.

Enums

Encoder 🔒

FieldPlan 🔒

Per‑site encoder plan for a field. This mirrors the Avro structure, so nested optional branch order can be honored exactly as declared by the schema.

KeyKind 🔒

Internal key array kind used by Map encoder.

NullState 🔒

Traits

DecimalBeBytes 🔒

Minimal trait to obtain a big-endian fixed-size byte array for a decimal’s unscaled integer value at idx.

IntervalToDurationParts 🔒

Trait mapping an Arrow interval native value to Avro duration (months, days, millis).

Functions

encode_blocked_range 🔒

Encode a blocked range of items with Avro array block framing.

find_map_value_field_index 🔒

find_struct_child_index 🔒

minimal_twos_complement 🔒

Minimal two’s-complement big-endian representation helper for Avro decimal (bytes).

union_value_branch_byte 🔒

write_bool 🔒

write_int 🔒

write_len_prefixed 🔒

write_long 🔒

Encode a single Avro-long using ZigZag + variable length, buffered.

write_optional_index 🔒

Write the union branch index for an optional field.

write_sign_extended 🔒

Sign-extend (or validate/truncate) big-endian integer bytes to exactly n bytes.

Type Aliases

Decimal32Encoder 🔒

Decimal64Encoder 🔒

Decimal128Encoder 🔒

Decimal256Encoder 🔒

ListEncoder32 🔒

ListEncoder64 🔒

ListViewEncoder32 🔒

ListViewEncoder64 🔒

RunEncodedEncoder16 🔒

RunEncodedEncoder32 🔒

RunEncodedEncoder64 🔒

Utf8Encoder 🔒

Utf8LargeEncoder 🔒