展开描述
将 RecordBatch 编码为 Avro 二进制格式。用于 Arrow 类型的 Avro 编码器。
结构体§
- Binary
Encoder 🔒 - 统一的二进制编码器，可处理不同偏移量大小 (i32/i64) 的泛型。
- Binary
View 🔒Encoder - BinaryView (字节视图) 编码器。
- Boolean
Encoder 🔒 - Decimal
Encoder 🔒 - 用于 Arrow 十进制数组的通用 Avro 十进制编码器。
- Duration
Encoder 🔒 - 用于所有三种间隔单位的单一通用编码器。一次调用将 Avro
fixed(12)写入为三个小端 u32 值。 - Duration
Parts 🔒 - Enum
Encoder 🔒 - 用于 Arrow
DictionaryArray<Int32, Utf8>的 Avroenum编码器。 - F32Encoder 🔒
- F64Encoder 🔒
- Field
Binding 🔒 - Field
Encoder 🔒 - Arrow 到 Avro 的 FieldEncoder
- Fixed
Encoder 🔒 - 用于 Arrow
FixedSizeBinaryArray的 Avrofixed编码器。规范：一个 fixed 编码为精确的size字节，没有长度前缀。 - Fixed
Size 🔒List Encoder - FixedSizeList 编码器。
- IntEncoder 🔒
- 用于原始数组的通用 Avro
int编码器，具有i32本机值。 - List
Encoder 🔒 - List
View 🔒Encoder - 使用
(offset, size)缓冲区的 ListView 编码器。 - Long
Encoder 🔒 - 用于原始数组的通用 Avro
long编码器，具有i64本机值。 - MapEncoder 🔒
- Record
Encoder 🔒 - 用于将
RecordBatch编码为 Avro 的预计算计划。 - Record
Encoder 🔒Builder RecordEncoder写入计划的构建器- RunEncoded
Encoder 🔒 - 用于基于 Arrow
RunArray<R>站点的通用编码器（游程编码）。遵循其他通用编码器（即ListEncoder<O>）使用的模式，避免在游程结束宽度上进行运行时分支。 - Struct
Encoder 🔒 - Time32
Seconds 🔒ToMillis Encoder - Time32(Second) 到 Avro time-millis (int)，通过安全地乘以 1000 进行缩放
- Timestamp
Seconds 🔒ToMillis Encoder - Timestamp(Second) 到 Avro timestamp-millis (long)，通过安全地乘以 1000 进行缩放
- Union
Encoder 🔒 - Utf8
Generic 🔒Encoder - Utf8
View 🔒Encoder - StringView 编码器。
- Uuid
Encoder 🔒 - Avro UUID 逻辑类型编码器：Arrow FixedSizeBinary(16) 到 Avro string (UUID)。规范：uuid 是 string 上的逻辑类型 (RFC‑4122)。我们输出带连字符的形式。
枚举§
- Encoder 🔒
- Field
Plan 🔒 - 字段的每个站点的编码器计划。这反映了 Avro 结构，因此嵌套的可选分支顺序可以完全按照模式声明的方式进行。
- KeyKind 🔒
- Map 编码器使用的内部键数组类型。
- Null
State 🔒
Trait§
- Decimal
BeBytes 🔒 - 最小的 trait，用于获取十进制未缩放整数值在
idx处的 big-endian 固定大小字节数组。 - Interval
ToDuration 🔒Parts - 将 Arrow 间隔本机值映射到 Avro 持续时间
(months, days, millis)的 trait。
函数§
- encode_
blocked_ 🔒range - 使用 Avro 数组块帧编码项目的阻塞范围。
- find_
map_ 🔒value_ field_ index - find_
struct_ 🔒child_ index - minimal_
twos_ 🔒complement - Avro 十进制 (bytes) 的最小补码大端表示辅助函数。
- prepare_
value_ 🔒site_ encoder - union_
value_ 🔒branch_ byte - write_
bool 🔒 - write_
int 🔒 - write_
len_ 🔒prefixed - write_
long 🔒 - 使用 ZigZag + 可变长度，缓冲编码单个 Avro-
long。 - write_
optional_ 🔒index - 写入可选字段的联合分支索引。
- write_
sign_ 🔒extended - 将 big-endian 整数字节进行符号扩展（或验证/截断）以精确到
n字节。