Struct lance_encoding::encodings::logical::binary::BinaryPageDecoder

pub struct BinaryPageDecoder { /* private fields */ }

Trait Implementations

impl LogicalPageDecoder for BinaryPageDecoder

fn wait<'a>( &'a mut self, num_rows: u32, source: &'a mut UnboundedReceiver<Box<dyn LogicalPageDecoder>> ) -> BoxFuture<'a, 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 unawaited(&self) -> u32

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

fn avail(&self) -> u32

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