query::executor

Trait QueryExecutor

source 
pub trait QueryExecutor {
    // Required method
    fn execute_stream(
        &self,
        ctx: &QueryEngineContext,
        plan: &Arc<dyn ExecutionPlan>,
    ) -> Result<SendableRecordBatchStream>;
}
Expand description

Executor to run [PhysicalPlan].

Required Methods§

source

fn execute_stream( &self, ctx: &QueryEngineContext, plan: &Arc<dyn ExecutionPlan>, ) -> Result<SendableRecordBatchStream>

Implementors§