Struct PhysicalVecSource 

pub struct PhysicalVecSource { /* private fields */ }

In-memory positional source that preserves a structured RowSchema and shared physical row fragments without round-tripping through named maps.

Implementations

impl PhysicalVecSource

pub fn new(schema: RowSchema, rows: Vec<PhysicalRow>) -> Self

Trait Implementations

impl RowSource for PhysicalVecSource

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 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 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 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.