结构体 RecordDecoder 

pub(crate) struct RecordDecoder {
    schema: SchemaRef,
    fields: Vec<Decoder>,
    projector: Option<Projector>,
}

将 Avro 编码数据解码为 [RecordBatch]

字段

schema: SchemaRef

fields: Vec<Decoder>

projector: Option<Projector>

实现

impl RecordDecoder

pub(crate) fn try_new_with_options( data_type: &AvroDataType, ) -> Result<Self, ArrowError>

使用提供的 AvroDataType 和额外选项创建一个新的 RecordDecoder。

此方法允许您自定义 Avro 数据如何解码为 Arrow 数组。

参数

• data_type - 要解码的 Avro 数据类型。
• use_utf8view - 一个标志，指示是否对字符串类型使用 Utf8View。

错误

如果提供的 data_type 不是 Record，此函数将返回错误。

pub(crate) fn schema(&self) -> &SchemaRef

返回解码器的 SchemaRef

pub(crate) fn decode( &mut self, buf: &[u8], count: usize, ) -> Result<usize, ArrowError>

从 buf 解码 count 条记录

pub(crate) fn flush(&mut self) -> Result<RecordBatch, ArrowError>

将解码的记录刷新到 [RecordBatch]

Trait 实现

impl Debug for RecordDecoder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

使用给定的格式化程序格式化值。 阅读更多