Struct TableScan 

pub struct TableScan { /* private fields */ }

TableScan: a leaf operator that drains its RowSource.

Emits batches of at most DEFAULT_BATCH_SIZE rows. Idempotent open / close so the operator can be re-opened in tests.

Implementations

impl TableScan

pub fn new(source: Box<dyn RowSource>) -> Self

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

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

pub fn from_rows_with_schema(schema: RowSchema, rows: Vec<ResultRow>) -> Self

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

Trait Implementations

impl PhysicalOperator for TableScan

fn row_schema(&self) -> &RowSchema

Complete logical-to-physical row layout emitted by this operator. Every Batch returned by Self::next must carry this exact schema; operators must reject a child that violates that invariant.

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

Planner/runtime cardinality estimate for choosing physical strategies. None means the operator cannot provide a useful estimate. The value is advisory rather than a correctness bound.

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

Leading output ordering known to be preserved by this operator.

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

Let a leaf consume its native projected rows directly into an aggregate executor. Returning false promises that no input was consumed, so the caller can fall back to ordinary Batch pulls.

fn open(&mut self) -> ExecResult<()>

fn next(&mut self) -> ExecResult<Option<Batch>>

fn close(&mut self) -> ExecResult<()>

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

Schema column names in logical output order.