Struct QueryExecutor 

pub struct QueryExecutor { /* private fields */ }

Query executor for parsed SQL queries

Implementations

impl QueryExecutor

pub const fn new() -> Self

Create a new query executor with cost-based backend selection

pub const fn with_backend(backend: Backend) -> Self

Create executor with forced backend

pub fn execute( &self, plan: &QueryPlan, storage: &StorageEngine, ) -> Result<RecordBatch>

Execute a query plan against storage

Arguments

• plan - Parsed query plan from QueryEngine::parse()
• storage - Storage engine containing the data

Returns

Result record batch with query results

Errors

Returns error if:

• Table not found in storage
• Column not found in schema
• Data type mismatch
• Backend execution failure

Example

use trueno_db::query::{QueryEngine, QueryExecutor};
use trueno_db::storage::StorageEngine;

let storage = StorageEngine::load_parquet("data/events.parquet")?;
let engine = QueryEngine::new();
let executor = QueryExecutor::new();

let plan = engine.parse("SELECT category, SUM(value) FROM events GROUP BY category")?;
let result = executor.execute(&plan, &storage)?;

println!("Results: {} rows", result.num_rows());

Trait Implementations

impl Default for QueryExecutor

fn default() -> Self

Returns the “default value” for a type.