Struct ColumnStream 

pub struct ColumnStream<'table, 'a, P = MemPager>
where
    P: Pager<Blob = EntryHandle> + Send + Sync,
{ /* private fields */ }

Streaming view over a set of row IDs for selected logical fields.

ColumnStream keeps a reusable gather context so repeated calls avoid reparsing column descriptors or re-fetching chunk metadata. Each call to ColumnStream::next_batch returns at most STREAM_BATCH_ROWS values, backed by Arrow arrays without copying the column data.

Implementations

impl<'table, 'a, P> ColumnStream<'table, 'a, P>

where P: Pager<Blob = EntryHandle> + Send + Sync,

pub fn total_rows(&self) -> usize

Total number of row IDs covered by this stream.

pub fn remaining_rows(&self) -> usize

Remaining number of row IDs that have not yet been yielded.

pub fn logical_fields(&self) -> &[LogicalFieldId]

Logical fields produced by this stream.

pub fn next_batch(&mut self) -> LlkvResult<Option<ColumnStreamBatch>>

Fetch the next chunk of rows, if any remain.