Struct VecSource 

pub struct VecSource { /* private fields */ }

In-memory source from a precomputed Vec<ResultRow>. Useful for tests and for materialising CTE bodies.

Implementations

impl VecSource

pub fn new(schema: Vec<String>, rows: Vec<ResultRow>) -> Self

pub fn with_row_schema(physical_schema: RowSchema, rows: Vec<ResultRow>) -> Self

pub fn with_types( schema: Vec<String>, types: Vec<Option<ColumnType>>, rows: Vec<ResultRow>, ) -> Self

Trait Implementations

impl RowSource for VecSource

fn schema(&self) -> &[String]

Stable column order for the rows produced by Self::next_row.

fn physical_schema(&self) -> Option<&RowSchema>

Optional non-identity schema used by positional sources. This carries hidden lookup aliases and slot remaps that cannot be represented by the legacy column-name slice.

fn estimated_cardinality(&self) -> Option<u64>

Estimated total rows available from this source.

fn next_row(&mut self) -> ExecResult<Option<ResultRow>>

Pull the next row. Returns None when the source is exhausted.

fn output_ordering(&self) -> &[PhysicalOrder]

Leading row order guaranteed by the source.

fn next_batch(&mut self, max_rows: usize) -> ExecResult<Vec<ResultRow>>

Pull up to max_rows without forcing batch-capable sources through a row-at-a-time lock or backend call. The default preserves compatibility for iterator-like sources.

fn next_physical_batch( &mut self, max_rows: usize, ) -> ExecResult<Vec<PhysicalRow>>

Pull a positional batch directly. Backend-native sources override this to avoid constructing named maps at the scan boundary; compatibility sources are converted exactly once here.

fn consume_into_aggregate( &mut self, _executor: &mut dyn AggregateExecutor, ) -> ExecResult<bool>

Feed backend-native projected rows directly to an aggregate. Sources that cannot preserve their normal filter and virtual-column semantics return false without advancing their cursor.