结构体 HeaderDecoder 

pub struct HeaderDecoder {
    state: HeaderDecoderState,
    vlq_decoder: VLQDecoder,
    meta_offsets: Vec<usize>,
    meta_buf: Vec<u8>,
    sync_marker: [u8; 16],
    tuples_remaining: usize,
    bytes_remaining: usize,
}

Header 的解码器

Avro 文件格式不编码头部长度，因此需要提供一个基于推的解码器，以便与流一起使用

字段

state: HeaderDecoderState

vlq_decoder: VLQDecoder

meta_offsets: Vec<usize>

meta_buf 中字符串的结束偏移量

meta_buf: Vec<u8>

元数据映射的原始二进制数据

sync_marker: [u8; 16]

已解码的同步标记

tuples_remaining: usize

当前块中剩余的元组数量

bytes_remaining: usize

当前字符串/字节负载中剩余的字节数

实现

impl HeaderDecoder

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

从 buf 解析 Header，返回读取的字节数

此方法可以与连续的数据块多次调用，从而实现与分块 IO 系统（如 BufRead::fill_buf）的集成

所有错误都应被视为致命错误，并中止解码

一旦整个 Header 已解码，此方法将不再读取任何进一步的输入字节，并且可以通过 Self::flush 获取头部

pub fn flush(&mut self) -> Option<Header>

刷新此解码器，返回已解析的 Header（如果有）

Trait 实现

impl Debug for HeaderDecoder

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

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

impl Default for HeaderDecoder

fn default() -> Self

返回某个类型的“默认值”。阅读更多