edu.iu.dsc.tws.task.cdfw

Class CDFWScheduler

java.lang.Object

edu.iu.dsc.tws.task.cdfw.CDFWScheduler

All Implemented Interfaces:

ICDFWScheduler

public class CDFWScheduler
extends java.lang.Object
implements ICDFWScheduler

This schedule is the base method for making decisions to run the part of the task graph which will be improved further with the complex logic. Now, based on the relations(parent -> child) it will initiate the execution.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CDFWScheduler(java.util.List<JobMasterAPI.WorkerInfo> workerInfoList)

Method Summary

Modifier and Type	Method and Description
java.util.Map<DataFlowGraph,java.util.Set<java.lang.Integer>>	schedule(DataFlowGraph... dataFlowGraphs) This method is able to schedule multiple dataflow graphs.
java.util.Set<java.lang.Integer>	schedule(DataFlowGraph graphJob)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CDFWScheduler

protected CDFWScheduler(java.util.List<JobMasterAPI.WorkerInfo> workerInfoList)

Method Detail

schedule

public java.util.Set<java.lang.Integer> schedule(DataFlowGraph graphJob)

Specified by:

schedule in interface ICDFWScheduler

schedule

public java.util.Map<DataFlowGraph,java.util.Set<java.lang.Integer>> schedule(DataFlowGraph... dataFlowGraphs)

This method is able to schedule multiple dataflow graphs. It will return the map which corresponds to the dataflow graph and their worker ids.

Specified by:

schedule in interface ICDFWScheduler