edu.iu.dsc.tws.tsched.batch.batchscheduler

Class BatchTaskScheduler

java.lang.Object

edu.iu.dsc.tws.tsched.batch.batchscheduler.BatchTaskScheduler

All Implemented Interfaces:

ITaskScheduler

public class BatchTaskScheduler
extends java.lang.Object
implements ITaskScheduler

This scheduler is capable of handling of single task graph as well as multiple task graphs. It first validates the parallelism of receptor and collector tasks then it invoke the schedule method to schedule the individual task graphs.

Constructor Summary

Constructors

Constructor and Description
BatchTaskScheduler()

Method Summary

Modifier and Type	Method and Description
void	initialize(Config cfg) This method initialize the task instance values with the values specified in the task config object.
void	initialize(Config cfg, int workerid) Initialize with the worker id
TaskSchedulePlan	schedule(ComputeGraph computeGraph, WorkerPlan workerPlan) This is the base method which receives the dataflow taskgraph and the worker plan to allocate the task instances to the appropriate workers with their required ram, disk, and cpu values.
java.util.Map<java.lang.String,TaskSchedulePlan>	schedule(WorkerPlan workerPlan, ComputeGraph... computeGraphs) This method receives the worker plan and the dataflow graph as a variable argument which may have multiple dataflow graphs.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchTaskScheduler

public BatchTaskScheduler()

Method Detail

initialize

public void initialize(Config cfg)

This method initialize the task instance values with the values specified in the task config object.

Specified by:

initialize in interface ITaskScheduler

Parameters:

cfg - configuration object

initialize

public void initialize(Config cfg,
                       int workerid)

Description copied from interface: ITaskScheduler

Initialize with the worker id

Specified by:

initialize in interface ITaskScheduler

Parameters:

cfg - configuration

workerid - this worker id

schedule

public java.util.Map<java.lang.String,TaskSchedulePlan> schedule(WorkerPlan workerPlan,
                                                                 ComputeGraph... computeGraphs)

This method receives the worker plan and the dataflow graph as a variable argument which may have multiple dataflow graphs. First, it will do the validation of the parallelism values for the receptor and collector tasks and then invoke the schedule() method to schedule the individual task graphs.

schedule

public TaskSchedulePlan schedule(ComputeGraph computeGraph,
                                 WorkerPlan workerPlan)

This is the base method which receives the dataflow taskgraph and the worker plan to allocate the task instances to the appropriate workers with their required ram, disk, and cpu values.

Specified by:

schedule in interface ITaskScheduler

Parameters:

computeGraph -

workerPlan - worker plan

Returns: