edu.iu.dsc.tws.tsched.streaming.roundrobin

Class RoundRobinTaskScheduler

java.lang.Object

edu.iu.dsc.tws.tsched.streaming.roundrobin.RoundRobinTaskScheduler

All Implemented Interfaces:

ITaskScheduler

public class RoundRobinTaskScheduler
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 containers which is based on the task configuration values and the allocated worker 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
RoundRobinTaskScheduler()

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

RoundRobinTaskScheduler

public RoundRobinTaskScheduler()

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:

TaskSchedulePlan