Struct BlockDecoder

pub struct BlockDecoder {
    state: BlockDecoderState,
    in_progress: Block,
    vlq_decoder: VLQDecoder,
    bytes_remaining: usize,
}

A decoder for Block

Fields

state: BlockDecoderState

in_progress: Block

vlq_decoder: VLQDecoder

bytes_remaining: usize

Implementations

impl BlockDecoder

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

Parse Block from buf, returning the number of bytes read

This method can be called multiple times with consecutive chunks of data, allowing integration with chunked IO systems like BufRead::fill_buf

All errors should be considered fatal, and decoding aborted

Once an entire Block has been decoded this method will not read any further input bytes, until Self::flush is called. Afterwards Self::decode can then be used again to read the next block, if any

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

Flush this decoder returning the parsed Block if any

Trait Implementations

impl Debug for BlockDecoder

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

Formats the value using the given formatter.

impl Default for BlockDecoder

fn default() -> Self

Returns the “default value” for a type.