Struct DictionaryDecoder

pub struct DictionaryDecoder<'a> { /* private fields */ }

Decoder for Dictionary encoding.

Implementations

impl<'a> DictionaryDecoder<'a>

pub fn new( reader: &'a dyn Reader, position: usize, length: usize, data_type: &'a DataType, value_arr: ArrayRef, ) -> Self

Trait Implementations

impl AsyncIndex<ReadBatchParams> for DictionaryDecoder<'_>

type Output = Result<Arc<dyn Array>, Error>

fn get<'life0, 'async_trait>( &'life0 self, params: ReadBatchParams, ) -> Pin<Box<dyn Future<Output = Self::Output> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl AsyncIndex<usize> for DictionaryDecoder<'_>

type Output = Result<Arc<dyn Array>, Error>

fn get<'life0, 'async_trait>( &'life0 self, _index: usize, ) -> Pin<Box<dyn Future<Output = Self::Output> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl Debug for DictionaryDecoder<'_>

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

Formats the value using the given formatter.

impl Decoder for DictionaryDecoder<'_>

fn decode<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ArrayRef>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn take<'life0, 'life1, 'async_trait>( &'life0 self, indices: &'life1 UInt32Array, ) -> Pin<Box<dyn Future<Output = Result<ArrayRef>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Take by indices.