Trait Decoder

pub trait Decoder: Send + AsyncIndex<ReadBatchParams> {
    // Required methods
    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;
}

Decoder - Read Arrow Data.

Required Methods

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.

Implementors

impl Decoder for DictionaryDecoder<'_>

impl Decoder for PlainDecoder<'_>

impl<T: ByteArrayType> Decoder for BinaryDecoder<'_, T>