Struct BinaryDecoder

pub struct BinaryDecoder<'a, T: ByteArrayType> { /* private fields */ }

Var-binary encoding decoder.

Implementations

impl<'a, T: ByteArrayType> BinaryDecoder<'a, T>

Var-length Binary Decoder

pub fn new( reader: &'a dyn Reader, position: usize, length: usize, nullable: bool, ) -> Self

Create a BinaryEncoder to decode one batch.

• position, file position where this batch starts.
• length, the number of records in this batch.
• nullable, whether this batch contains nullable value.

Example

use arrow_array::types::Utf8Type;
use object_store::path::Path;
use lance_io::{local::LocalObjectReader, encodings::binary::BinaryDecoder, traits::Reader};

async {
    let reader = LocalObjectReader::open_local_path("/tmp/foo.lance", 2048, None).await.unwrap();
    let string_decoder = BinaryDecoder::<Utf8Type>::new(reader.as_ref(), 100, 1024, true);
};

Trait Implementations

impl<T: ByteArrayType> AsyncIndex<Range<usize>> for BinaryDecoder<'_, T>

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

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

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

impl<T: ByteArrayType> AsyncIndex<RangeFrom<usize>> for BinaryDecoder<'_, T>

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

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

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

impl<T: ByteArrayType> AsyncIndex<RangeFull> for BinaryDecoder<'_, T>

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

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

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

impl<T: ByteArrayType> AsyncIndex<RangeTo<usize>> for BinaryDecoder<'_, T>

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

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

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

impl<T: ByteArrayType> AsyncIndex<ReadBatchParams> for BinaryDecoder<'_, T>

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<T: ByteArrayType> AsyncIndex<usize> for BinaryDecoder<'_, T>

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<T: ByteArrayType> Decoder for BinaryDecoder<'_, T>

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 the values at the given indices.

This function assumes indices are sorted.

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

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