Struct DataChunk 

pub struct DataChunk { /* private fields */ }

A batch of tuples in columnar layout.

Rows 0..len hold data; sel narrows which rows are “live” after filtering. When sel is None, all rows 0..len are live (avoids allocation on non- filtering operators).

Implementations

impl DataChunk

pub fn empty() -> Self

Create an empty chunk with no columns and no rows.

pub fn from_columns(columns: Vec<ColumnVector>) -> Self

Create a chunk from a set of column vectors.

Panics

Panics in debug mode if columns have different lengths.

pub fn from_two_vecs( col0_id: u32, col0: Vec<u64>, col1_id: u32, col1: Vec<u64>, ) -> Self

Create a chunk with exactly two u64 columns (typically src_slot, dst_slot).

Convenience constructor used by GetNeighbors.

pub fn len(&self) -> usize

Number of physical rows (before selection).

pub fn is_empty(&self) -> bool

pub fn live_len(&self) -> usize

Number of “live” rows after applying the selection vector.

pub fn column(&self, pos: usize) -> &ColumnVector

Get a reference to a column by position.

pub fn column_mut(&mut self, pos: usize) -> &mut ColumnVector

Get a mutable reference to a column by position.

pub fn num_columns(&self) -> usize

Number of columns.

pub fn find_column(&self, col_id: u32) -> Option<&ColumnVector>

Find a column by col_id. Returns None if not present.

pub fn push_column(&mut self, col: ColumnVector)

Add a column to the chunk.

Panics

Panics in debug mode if the new column length differs from self.len.

pub fn sel(&self) -> Option<&[u32]>

Return the current selection vector, or None if all rows are live.

pub fn filter_sel<F>(&mut self, pred: F)

where F: FnMut(usize) -> bool,

Apply a predicate to each live row and update the selection vector.

pred receives the row index i and returns true if the row should remain live. Rows that return false are removed from sel.

This is the core Filter operation: it never copies column data, only updates the selection vector. O(live_len) time, O(1) extra memory (modifies sel in place).

pub fn live_rows(&self) -> LiveRows<'_>

Materialize this chunk into an iterator over live row indices.

When sel is None, yields 0..len. When sel is Some(sel), yields indices from the selection vector.

pub fn into_columns(self) -> Vec<ColumnVector>

Consume the chunk and extract its column vectors.

Trait Implementations

impl Clone for DataChunk

fn clone(&self) -> DataChunk

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DataChunk

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

Formats the value using the given formatter.