Trait parquet::decoding::Decoder

pub trait Decoder<T: DataType> {
    fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>;
    fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>;
    fn values_left(&self) -> usize;
    fn encoding(&self) -> Encoding;
}

A Parquet decoder for the data type T.

Required Methods

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

Sets the data to decode to be data, which should contain num_values of values to decode.

fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>

Consumes values from this decoder and write the results to buffer. This will try to fill up buffer.

Returns the actual number of values decoded, which should be equal to buffer.len() unless the remaining number of values is less than buffer.len().

fn values_left(&self) -> usize

Returns the number of values left in this decoder stream.

fn encoding(&self) -> Encoding

Returns the encoding for this decoder.

Implementors

impl Decoder<BoolType> for PlainDecoder<BoolType>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn get(&mut self, buffer: &mut [bool]) -> Result<usize>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl Decoder<BoolType> for RleValueDecoder<BoolType>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl Decoder<ByteArrayType> for DeltaByteArrayDecoder<ByteArrayType>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn get(&mut self, buffer: &mut [ByteArray]) -> Result<usize>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl Decoder<ByteArrayType> for DeltaLengthByteArrayDecoder<ByteArrayType>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn get(&mut self, buffer: &mut [ByteArray]) -> Result<usize>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl Decoder<ByteArrayType> for PlainDecoder<ByteArrayType>

fn get(&mut self, buffer: &mut [ByteArray]) -> Result<usize>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl Decoder<FixedLenByteArrayType> for DeltaByteArrayDecoder<FixedLenByteArrayType>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn get(&mut self, buffer: &mut [ByteArray]) -> Result<usize>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl Decoder<FixedLenByteArrayType> for PlainDecoder<FixedLenByteArrayType>

fn get(&mut self, buffer: &mut [ByteArray]) -> Result<usize>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl Decoder<Int96Type> for PlainDecoder<Int96Type>

fn get(&mut self, buffer: &mut [Int96]) -> Result<usize>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl<'m, T: DataType> Decoder<T> for DeltaByteArrayDecoder<T>

fn set_data(&mut self, _: ByteBufferPtr, _: usize) -> Result<()>

fn get(&mut self, _: &mut [T::T]) -> Result<usize>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl<T: DataType> Decoder<T> for DeltaBitPackDecoder<T>

fn set_data(&mut self, data: ByteBufferPtr, _: usize) -> Result<()>

fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl<T: DataType> Decoder<T> for DeltaLengthByteArrayDecoder<T>

fn set_data(&mut self, _: ByteBufferPtr, _: usize) -> Result<()>

fn get(&mut self, _: &mut [T::T]) -> Result<usize>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

impl<T: DataType> Decoder<T> for DictDecoder<T>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>

fn values_left(&self) -> usize

Number of values left in this decoder stream

fn encoding(&self) -> Encoding

impl<T: DataType> Decoder<T> for PlainDecoder<T>

fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>

impl<T: DataType> Decoder<T> for RleValueDecoder<T>

fn set_data(&mut self, _data: ByteBufferPtr, _num_values: usize) -> Result<()>

fn values_left(&self) -> usize

fn encoding(&self) -> Encoding

fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>