[−][src]Trait parquet::decoding::Decoder
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.
Provided methods
fn get_spaced(
&mut self,
buffer: &mut [T::T],
null_count: usize,
valid_bits: &[u8]
) -> Result<usize>
&mut self,
buffer: &mut [T::T],
null_count: usize,
valid_bits: &[u8]
) -> Result<usize>
Consume values from this decoder and write the results to buffer
, leaving
"spaces" for null values.
null_count
is the number of nulls we expect to see in buffer
, after reading.
valid_bits
stores the valid bit for each value in the buffer. It should contain
at least number of bits that equal to buffer.len()
.
Returns the actual number of values decoded.
Panics
Panics if null_count
is greater than buffer.len()
.
Implementors
impl Decoder<BoolType> for PlainDecoder<BoolType>
[src]
fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>
[src]
fn get(&mut self, buffer: &mut [bool]) -> Result<usize>
[src]
impl Decoder<BoolType> for RleValueDecoder<BoolType>
[src]
impl Decoder<ByteArrayType> for DeltaByteArrayDecoder<ByteArrayType>
[src]
fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>
[src]
fn get(&mut self, buffer: &mut [ByteArray]) -> Result<usize>
[src]
impl Decoder<ByteArrayType> for DeltaLengthByteArrayDecoder<ByteArrayType>
[src]
fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>
[src]
fn get(&mut self, buffer: &mut [ByteArray]) -> Result<usize>
[src]
impl Decoder<ByteArrayType> for PlainDecoder<ByteArrayType>
[src]
impl Decoder<FixedLenByteArrayType> for DeltaByteArrayDecoder<FixedLenByteArrayType>
[src]
fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>
[src]
fn get(&mut self, buffer: &mut [ByteArray]) -> Result<usize>
[src]
impl Decoder<FixedLenByteArrayType> for PlainDecoder<FixedLenByteArrayType>
[src]
impl Decoder<Int96Type> for PlainDecoder<Int96Type>
[src]
impl<'m, T: DataType> Decoder<T> for DeltaByteArrayDecoder<T>
[src]
default fn set_data(&mut self, _: ByteBufferPtr, _: usize) -> Result<()>
[src]
default fn get(&mut self, _: &mut [T::T]) -> Result<usize>
[src]
fn values_left(&self) -> usize
[src]
fn encoding(&self) -> Encoding
[src]
impl<T: DataType> Decoder<T> for DeltaBitPackDecoder<T>
[src]
default fn set_data(&mut self, data: ByteBufferPtr, _: usize) -> Result<()>
[src]
default fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>
[src]
fn values_left(&self) -> usize
[src]
fn encoding(&self) -> Encoding
[src]
impl<T: DataType> Decoder<T> for DeltaLengthByteArrayDecoder<T>
[src]
default fn set_data(&mut self, _: ByteBufferPtr, _: usize) -> Result<()>
[src]
default fn get(&mut self, _: &mut [T::T]) -> Result<usize>
[src]
fn values_left(&self) -> usize
[src]
fn encoding(&self) -> Encoding
[src]
impl<T: DataType> Decoder<T> for DictDecoder<T>
[src]
fn set_data(&mut self, data: ByteBufferPtr, num_values: usize) -> Result<()>
[src]
fn get(&mut self, buffer: &mut [T::T]) -> Result<usize>
[src]
fn values_left(&self) -> usize
[src]
Number of values left in this decoder stream
fn encoding(&self) -> Encoding
[src]
impl<T: DataType> Decoder<T> for PlainDecoder<T>
[src]
default fn set_data(
&mut self,
data: ByteBufferPtr,
num_values: usize
) -> Result<()>
[src]
&mut self,
data: ByteBufferPtr,
num_values: usize
) -> Result<()>