Module encoder

Expand description

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

Structs§

BinaryEncoder 🔒: Unified binary encoder generic over offset size (i32/i64).
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.
IntEncoder 🔒: Generic Avro int encoder for primitive arrays with i32 native values.
ListEncoder 🔒
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
StructEncoder 🔒
Utf8GenericEncoder 🔒
UuidEncoder 🔒: Avro UUID logical type encoder: Arrow FixedSizeBinary(16) → Avro string (UUID). Spec: uuid is a logical type over string (RFC‑4122). We output hyphenated form.

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 🔒

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

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.