Struct nando_lib::plans::plan_manager::PhysicalPlanManager

pub(crate) struct PhysicalPlanManager {
    parsed_plans: DashMap<String, ParsedPhysicalPlan>,
    planning_progress: DashMap<EcbId, usize>,
}

Fields

parsed_plans: DashMap<String, ParsedPhysicalPlan>

planning_progress: DashMap<EcbId, usize>

Implementations

impl PhysicalPlanManager

fn new(plan_directory_path: Option<PathBuf>) -> Self

fn load_baked_plans() -> DashMap<String, ParsedPhysicalPlan>

fn parse_plans( plan_directory: ReadDir, parsed_plans: &mut DashMap<String, ParsedPhysicalPlan> )

pub fn get_physical_plan_manager( plan_directory: Option<PathBuf> ) -> &'static Arc<PhysicalPlanManager>

pub fn process_post_and_next_steps( &self, committed_task: &mut ECB, committed_activation: &NandoActivation, local_executor_at_capacity: bool ) -> HashMap<SubmissionLocation, Vec<(SpawnedTask, Option<Schedulable>)>>

fn process_post( &self, committed_task: &mut ECB, committed_activation: &NandoActivation, committed_task_idx: usize, post_action_block: &PostActionBlock ) -> (HashMap<OwnershipInformationKey, OwnershipInformation>, HashMap<SubmissionLocation, Vec<(SpawnedTask, Option<Schedulable>)>>)

pub fn next_step_from_plan( &self, committed_task: &ECB, plan: &ParsedPhysicalPlan, ownership_change_tasks: HashMap<OwnershipInformationKey, OwnershipInformation>, pending_task_map: HashMap<SubmissionLocation, Vec<(SpawnedTask, Option<Schedulable>)>> ) -> HashMap<SubmissionLocation, Vec<(SpawnedTask, Option<Schedulable>)>>

pub fn next_step_without_plan( &self, committed_task_ecb: &mut ECB, at_capacity: bool ) -> HashMap<SubmissionLocation, Vec<(SpawnedTask, Option<Schedulable>)>>