Module encoder 

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

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.

IntEncoder 🔒

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

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

TimestampSecondsToMillisEncoder 🔒

Timestamp(Second) to Avro timestamp-millis (long), via safe scaling by 1000

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).

prepare_value_site_encoder 🔒

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 🔒