DistPlanner

datafusion_dist::planner

Trait DistPlanner 

Source 
pub trait DistPlanner:
    Debug
    + Send
    + Sync {
    // Required method
    fn plan_stages(
        &self,
        job_id: Uuid,
        plan: Arc<dyn ExecutionPlan>,
    ) -> DistResult<HashMap<StageId, Arc<dyn ExecutionPlan>>>;
}

Required Methods§

Source

fn plan_stages( &self, job_id: Uuid, plan: Arc<dyn ExecutionPlan>, ) -> DistResult<HashMap<StageId, Arc<dyn ExecutionPlan>>>

Implementors§