kapot_executor::execution_engine

Trait ExecutionEngine

Source 
pub trait ExecutionEngine: Sync + Send {
    // Required method
    fn create_query_stage_exec(
        &self,
        job_id: String,
        stage_id: usize,
        plan: Arc<dyn ExecutionPlan>,
        work_dir: &str,
    ) -> Result<Arc<dyn QueryStageExecutor>>;
}
Expand description

Execution engine extension point

Required Methods§

Source

fn create_query_stage_exec( &self, job_id: String, stage_id: usize, plan: Arc<dyn ExecutionPlan>, work_dir: &str, ) -> Result<Arc<dyn QueryStageExecutor>>

Implementors§