Struct RepetitionLevelDecoderImpl

pub struct RepetitionLevelDecoderImpl {
    decoder: Option<LevelDecoder>,
    bit_width: u8,
    buffer: Box<[i16; 1024]>,
    buffer_len: usize,
    buffer_offset: usize,
    has_partial: bool,
}

An implementation of RepetitionLevelDecoder for [i16]

Fields

decoder: Option<LevelDecoder>

bit_width: u8

buffer: Box<[i16; 1024]>

buffer_len: usize

buffer_offset: usize

has_partial: bool

Implementations

impl RepetitionLevelDecoderImpl

pub fn new(max_level: i16) -> Self

fn fill_buf(&mut self) -> Result<()>

fn count_records( &mut self, records_to_read: usize, num_levels: usize, ) -> (bool, usize, usize)

Inspects the buffered repetition levels in the range self.buffer_offset..self.buffer_len and returns the number of “complete” records along with the corresponding number of values

A “complete” record is one where the buffer contains a subsequent repetition level of 0

Trait Implementations

impl ColumnLevelDecoder for RepetitionLevelDecoderImpl

type Buffer = Vec<i16>

fn set_data(&mut self, encoding: Encoding, data: Bytes)

Set data for this ColumnLevelDecoder

impl RepetitionLevelDecoder for RepetitionLevelDecoderImpl

fn read_rep_levels( &mut self, out: &mut Self::Buffer, num_records: usize, num_levels: usize, ) -> Result<(usize, usize)>

Read up to max_records of repetition level data into out returning the number of complete records and levels read

fn skip_rep_levels( &mut self, num_records: usize, num_levels: usize, ) -> Result<(usize, usize)>

Skips over up to num_levels repetition levels corresponding to num_records records, where a record is delimited by a repetition level of 0

fn flush_partial(&mut self) -> bool

Flush any partially read or skipped record