模块 record

模块 record 

源代码
展开描述

Arrow 类型的 Avro 解码器。

§

append_decimal_default 🔒
宏,用于将默认的十进制值从二进制补码大端字节追加到相应的十进制构建器中,并带有编译时构造的错误文本。
decode_decimal 🔒
宏,用于解码给定宽度和整数类型的十进制有效负载。
flush_decimal 🔒
宏,用于将十进制构建器完成为一个带有精度/刻度和空值的数组。

结构体§

DispatchLookupTable 🔒
EnumResolution 🔒
Projector 🔒
ProjectorBuilder 🔒
RecordDecoder 🔒
将 Avro 编码数据解码为 [RecordBatch]
UnionDecoder 🔒
UnionDecoderBuilder 🔒

枚举§

Decoder 🔒
NegativeBlockBehavior 🔒
NullablePlan 🔒
用于解码读取器端 ["null", T] 类型的运行时计划。
Skipper 🔒
用于非投影写入器字段(存在于写入器模式中但被读取器/投影省略的字段)的轻量级跳过器;根据 Avro 1.11.1 模式解析,这些字段将被忽略。
UnionReadPlan 🔒

常量§

DEFAULT_CAPACITY 🔒
NO_SOURCE 🔒

函数§

flush_dict 🔒
flush_offsets 🔒
flush_primitive 🔒
flush_values 🔒
process_blockwise 🔒
read_blocks 🔒
read_decimal_bytes_be 🔒
sign_cast_to 🔒
将大端二进制补码整数进行符号扩展或(当较大时)验证和截断为精确的 N 字节。这与 Avro 的十进制二进制编码匹配:有效负载是一个大端二进制补码整数,在缩窄时必须能够表示而不会改变符号或值。
skip_blocks 🔒
values_equal_at 🔒