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