Struct lance_encoding::encodings::logical::struct::SimpleStructDecoder

pub struct SimpleStructDecoder { /* private fields */ }

Implementations

impl SimpleStructDecoder

pub fn avail_u64(&self) -> u64

pub fn unawaited_u64(&self) -> u64

pub fn wait_u64(&mut self, num_rows: u64) -> BoxFuture<'_, Result<()>>

pub fn drain_u64(&mut self, num_rows: u64) -> Result<NextDecodeTask>

Trait Implementations

impl Debug for SimpleStructDecoder

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

Formats the value using the given formatter.

impl LogicalPageDecoder for SimpleStructDecoder

fn accept_child(&mut self, child: DecoderReady) -> Result<()>

Add a newly scheduled child decoder

fn wait(&mut self, num_rows: u32) -> BoxFuture<'_, Result<()>>

Waits for enough data to be loaded to decode num_rows of data

fn drain(&mut self, num_rows: u32) -> Result<NextDecodeTask>

Creates a task to decode num_rows of data into an array

fn avail(&self) -> u32

The number of rows that have been “waited” but not yet decoded

fn unawaited(&self) -> u32

The number of rows that are in the page but haven’t yet been “waited”

fn data_type(&self) -> &DataType

The data type of the decoded data