Struct OptimizedExecutor 

pub struct OptimizedExecutor { /* private fields */ }

Optimized query executor with cost-based planning

Implementations

impl OptimizedExecutor

pub fn new() -> Self

Create a new optimized executor

pub fn with_cost_model(cost_model: CostModel) -> Self

Create with custom cost model

pub fn with_cardinality_tracker(tracker: Arc<CardinalityTracker>) -> Self

Create with shared cardinality tracker (for integration with ingestion)

pub fn set_embedding_provider(&mut self, provider: Arc<dyn EmbeddingProvider>)

Set embedding provider for vector search

pub fn with_embedding_provider( self, provider: Arc<dyn EmbeddingProvider>, ) -> Self

Create with embedding provider

pub fn cardinality_tracker(&self) -> Arc<CardinalityTracker>

Get the cardinality tracker for external updates (e.g., on INSERT)

pub fn update_table_stats(&mut self, table: &str, stats: TableStats)

Update table statistics (call periodically or on schema change)

pub fn refresh_stats_from_tracker(&mut self, table: &str)

Refresh stats from cardinality tracker

Syncs real-time HLL estimates to the static stats cache.

pub fn update_cardinality_hint( &mut self, table: &str, column: &str, cardinality: usize, _source: CardinalitySource, )

Update column cardinality from HyperLogLog

pub fn plan_select( &self, select: &SelectQuery, _catalog: &Catalog, ) -> Result<OptimizedQueryPlan>

Plan a SELECT query with cost-based optimization

pub fn execute<S: StorageBackend>( &self, plan: &OptimizedQueryPlan, storage: &S, ) -> Result<SochResult>

Execute an optimized query plan against a storage backend

This is the key method that wires the optimizer output to actual storage. It interprets each ExecutionStep and calls the appropriate storage method.

pub fn explain(&self, select: &SelectQuery, catalog: &Catalog) -> Result<String>

Explain a query plan (for debugging)

Trait Implementations

impl Default for OptimizedExecutor

fn default() -> Self

Returns the “default value” for a type.