Expand description
Encodes RecordBatch
into the Avro binary format.
Avro Encoder for Arrow types.
StructsΒ§
- Binary
Encoder π - Unified binary encoder generic over offset size (i32/i64).
- Binary
View πEncoder - BinaryView (byte view) encoder.
- Boolean
Encoder π - Decimal
Encoder π - Generic Avro decimal encoder over Arrow decimal arrays.
- Duration
Encoder π - Single generic encoder used for all three interval units.
Writes Avro
fixed(12)
as three little-endian u32 values in one call. - Duration
Parts π - Enum
Encoder π - Avro
enum
encoder for ArrowDictionaryArray<Int32, Utf8>
. - F32Encoder π
- F64Encoder π
- Field
Binding π - Field
Encoder π - Arrow to Avro FieldEncoder:
- Fixed
Encoder π - Avro
fixed
encoder for ArrowFixedSizeBinaryArray
. Spec: a fixed is encoded as exactlysize
bytes, with no length prefix. - Fixed
Size πList Encoder - FixedSizeList encoder.
- IntEncoder π
- Generic Avro
int
encoder for primitive arrays withi32
native values. - List
Encoder π - List
View πEncoder - ListView encoder using
(offset, size)
buffers. - Long
Encoder π - Generic Avro
long
encoder for primitive arrays withi64
native values. - MapEncoder π
- Record
Encoder π - A pre-computed plan for encoding a
RecordBatch
to Avro. - Record
Encoder πBuilder - Builder for
RecordEncoder
write plan - RunEncoded
Encoder π - 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. - Struct
Encoder π - Time32
Seconds πToMillis Encoder - Time32(Second) to Avro time-millis (int), via safe scaling by 1000
- Timestamp
Seconds πToMillis Encoder - Timestamp(Second) to Avro timestamp-millis (long), via safe scaling by 1000
- Union
Encoder π - Utf8
Generic πEncoder - Utf8
View πEncoder - StringView encoder.
- Uuid
Encoder π - 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 π
- Field
Plan π - 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.
- Null
State π
TraitsΒ§
- Decimal
BeBytes π - Minimal trait to obtain a big-endian fixed-size byte array for a decimalβs
unscaled integer value at
idx
. - Interval
ToDuration πParts - 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Β§
- Decimal32
Encoder π - Decimal64
Encoder π - Decimal128
Encoder π - Decimal256
Encoder π - List
Encoder32 π - List
Encoder64 π - List
View πEncoder32 - List
View πEncoder64 - RunEncoded
Encoder16 π - RunEncoded
Encoder32 π - RunEncoded
Encoder64 π - Utf8
Encoder π - Utf8
Large πEncoder