Skip to main content

DistPlanner

datafusion_dist::planner

Trait DistPlanner 

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

Required Methods§

Source

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

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§