Struct lance_io::encodings::dictionary::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<'a> AsyncIndex<ReadBatchParams> for DictionaryDecoder<'a>

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<'a> AsyncIndex<usize> for DictionaryDecoder<'a>

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<'a> Decoder for DictionaryDecoder<'a>

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.