Struct Executor 

pub struct Executor { /* private fields */ }

The main query executor.

Builds an operator tree from a physical plan and executes it to produce results.

Implementations

impl Executor

pub fn new( plan: &PhysicalPlan, ctx: ExecutionContext, ) -> Result<Self, ParseError>

Creates a new executor for the given physical plan.

pub fn schema(&self) -> Arc<Schema>

Returns the output schema.

pub fn open(&mut self) -> Result<(), ParseError>

Opens the executor and prepares it to produce rows.

pub fn next(&mut self) -> Result<Option<Row>, ParseError>

Returns the next row, or None if there are no more rows.

pub fn close(&mut self) -> Result<(), ParseError>

Closes the executor and releases resources.

pub fn context(&self) -> &ExecutionContext

Returns the execution context.

pub fn state(&self) -> OperatorState

Returns the current state.

pub fn execute(&mut self) -> Result<QueryResult, ParseError>

Executes the query and collects all results.

pub fn collect(&mut self) -> Result<Vec<Row>, ParseError>

Executes and returns just the rows as a vector.

pub fn count(&mut self) -> Result<usize, ParseError>

Counts the number of result rows without materializing them.

pub fn first(&mut self) -> Result<Option<Row>, ParseError>

Returns the first row if any.