Struct QueryProcessor 

pub struct QueryProcessor { /* private fields */ }

The query processor executes a physical plan and produces result chunks.

Implementations

impl QueryProcessor

pub fn new() -> Self

pub fn with_registry(registry: Arc<Mutex<FunctionRegistry>>) -> Self

Create a processor with access to the function registry.

pub fn with_catalog( registry: Arc<Mutex<FunctionRegistry>>, table_catalog: Arc<TableCatalog>, vfs: Arc<VirtualFileSystemRegistry>, ) -> Self

Create a processor with function registry, table catalog access, and VFS.

pub fn with_standalone_call_handler( self, handler: Arc<dyn StandaloneCallHandler>, ) -> Self

Set the sequence operation callback (for nextval/currval).

pub fn with_sequence_fn(self, f: SequenceFn) -> Self

pub fn with_subquery_fn(self, f: SubqueryFn) -> Self

Set the subquery operation callback.

pub fn with_schema_ddl_fn(self, f: SchemaDdlFn) -> Self

Set the schema DDL callback (for CREATE/DROP SEQUENCE, EXPORT/IMPORT DATABASE).

pub fn with_snapshot( self, snapshot_ts: Option<u64>, commit_history: Vec<(u64, u64)>, ) -> Self

Set MVCC snapshot parameters for read isolation.

pub fn execute( &self, operators: &[LogicalOperator], ) -> Result<Vec<DataChunk>, ProcessorError>

Execute a sequence of logical operators by mapping them to physical operators.

pub fn execute_internal( &self, operators: &[LogicalOperator], ) -> Result<Vec<DataChunk>, ProcessorError>

pub fn take_written_rows(&self) -> Vec<(u64, u64)>

Take the accumulated write set from the processor. Returns all (table_id, row_id) pairs written during the last execution.

pub fn evaluate_expression( _expr: &Expression, _chunk: &DataChunk, ) -> Result<ValueVector, ProcessorError>

Execute a single expression against a DataChunk and return a ValueVector of results.

Trait Implementations

impl Default for QueryProcessor

fn default() -> Self

Returns the “default value” for a type.