Struct VectorSource 

pub struct VectorSource { /* private fields */ }

Source that produces chunks from a vector of values.

Useful for testing and for materializing intermediate results.

Implementations

impl VectorSource

pub fn new(columns: Vec<Vec<Value>>) -> Self

Create a new vector source from column data.

pub fn single_column(values: Vec<Value>) -> Self

Create a single-column source.

pub fn from_node_ids(ids: Vec<NodeId>) -> Self

Create from node IDs.

Trait Implementations

impl Source for VectorSource

fn next_chunk( &mut self, chunk_size: usize, ) -> Result<Option<DataChunk>, OperatorError>

Produce the next chunk of data.

fn reset(&mut self)

Reset the source to its initial state.

fn name(&self) -> &'static str

Name of this source for debugging.