Struct Executor 

pub struct Executor { /* private fields */ }

Executes a physical operator tree and collects results.

Implementations

impl Executor

pub fn new() -> Self

Creates a new executor.

pub fn with_columns(columns: Vec<String>) -> Self

Creates an executor with specified column names.

pub fn with_columns_and_types( columns: Vec<String>, column_types: Vec<LogicalType>, ) -> Self

Creates an executor with specified column names and types.

pub fn with_deadline(self, deadline: Option<Instant>) -> Self

Sets a wall-clock deadline for query execution.

pub fn with_timeout_duration(self, timeout: Option<Duration>) -> Self

Sets the original timeout duration (used for error messages).

pub fn execute(&self, operator: &mut dyn Operator) -> Result<QueryResult>

Executes a physical operator and collects all results.

Errors

Returns an error if operator execution fails or the query timeout is exceeded.

pub fn execute_pipeline( &self, source: Box<dyn Operator>, push_ops: Vec<Box<dyn PushOperator>>, ) -> Result<QueryResult>

Executes a push-based pipeline.

The source operator is wrapped in OperatorSource, push operators form the pipeline body, and a ChunkCollector gathers results.

Panics

Panics if the internal sink downcast fails (should never happen since we create the ChunkCollector ourselves).

Errors

Returns an error if pipeline execution fails or the query timeout is exceeded.

pub fn execute_with_limit( &self, operator: &mut dyn Operator, limit: usize, ) -> Result<QueryResult>

Executes and returns at most limit rows.

Errors

Returns an error if operator execution fails or the query timeout is exceeded.

pub fn execute_adaptive( &self, operator: Box<dyn Operator>, adaptive_context: Option<AdaptiveContext>, config: &AdaptiveConfig, ) -> Result<(QueryResult, Option<AdaptiveSummary>)>

Executes a physical operator with adaptive cardinality tracking.

This wraps the operator in a cardinality tracking layer and monitors deviation from estimates during execution. The adaptive summary is returned alongside the query result.

Arguments

• operator - The root physical operator to execute
• adaptive_context - Context with cardinality estimates from planning
• config - Adaptive execution configuration

Errors

Returns an error if operator execution fails.

Trait Implementations

impl Default for Executor

fn default() -> Self

Returns the “default value” for a type.