Trait dslab_mr::placement_strategy::PlacementStrategy

source · 
pub trait PlacementStrategy {
    // Required method
    fn place_stage(
        &mut self,
        dag_id: usize,
        stage: &Stage,
        graph: &Dag,
        input_data: &[DataItem],
        input_data_shuffled: &[Vec<DataItem>],
        dfs: &DistributedFileSystem,
        compute_host_info: &BTreeMap<Id, ComputeHost>,
        network: &Network
    ) -> Vec<TaskPlacement>;

    // Provided method
    fn register_dag(&mut self, _dag_id: usize, _graph: &Dag) { ... }
}
Expand description

Simplified placement strategy.

Contains only one place_stage functions which corresponds to DynamicPlacementStrategy::on_stage_ready and places all tasks right away.

Required Methods§

source

fn place_stage( &mut self, dag_id: usize, stage: &Stage, graph: &Dag, input_data: &[DataItem], input_data_shuffled: &[Vec<DataItem>], dfs: &DistributedFileSystem, compute_host_info: &BTreeMap<Id, ComputeHost>, network: &Network ) -> Vec<TaskPlacement>

Place all tasks of a given stage.

Provided Methods§

source

fn register_dag(&mut self, _dag_id: usize, _graph: &Dag)

Callback when new NewDag is received by Runner.

Implementors§