edu.iu.dsc.tws.tsched.batch.roundrobin

Class RoundRobinBatchTaskScheduler

java.lang.Object

edu.iu.dsc.tws.tsched.batch.roundrobin.RoundRobinBatchTaskScheduler

All Implemented Interfaces:

ITaskScheduler

public class RoundRobinBatchTaskScheduler
extends java.lang.Object
implements ITaskScheduler

This class allocate the task instances into the container in a round robin manner. First, it will allocate the task instances into the logical container values and then it will calculate the required ram, disk, and cpu values for task instances and the logical containers which is based on the task configuration values and the allocated work values respectively.

For example, if there are two tasks with parallelism value of 2, 1st task -> instance 0 will go to container 0, 2nd task -> instance 0 will go to container 1, 1st task -> instance 1 will go to container 1, 2nd task -> instance 1 will go to container 1.

Constructor Summary

Constructors

Constructor and Description
RoundRobinBatchTaskScheduler()

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

RoundRobinBatchTaskScheduler

public RoundRobinBatchTaskScheduler()

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 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 - graph

workerPlan - worker plan

Returns:

the task schedule