edu.iu.dsc.tws.tsched.taskscheduler

Class TaskScheduler

java.lang.Object

edu.iu.dsc.tws.tsched.taskscheduler.TaskScheduler

All Implemented Interfaces:

ITaskScheduler

public class TaskScheduler
extends java.lang.Object
implements ITaskScheduler

This class invokes the appropriate task schedulers based on the 'streaming' or 'batch' task types and scheduling modes 'roundrobin', 'firstfit', and 'datalocality'.

Constructor Summary

Constructors

Constructor and Description
TaskScheduler()

Method Summary

Modifier and Type	Method and Description
void	initialize(Config cfg) Intialize the task scheduler with the configuration
void	initialize(Config cfg, int workerid) Initialize with the worker id
TaskSchedulePlan	schedule(ComputeGraph graph, WorkerPlan plan) This is the base method for the task scheduler to invoke the appropriate task schedulers either "batch" or "streaming" based on the task type.
java.util.Map<java.lang.String,TaskSchedulePlan>	schedule(WorkerPlan plan, ComputeGraph... graphs) This is the base method for the task scheduler to invoke the appropriate task schedulers either "batch" or "streaming" based on the task type.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskScheduler

public TaskScheduler()

Method Detail

initialize

public void initialize(Config cfg)

Description copied from interface: ITaskScheduler

Intialize the task scheduler with the configuration

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 graph,
                                 WorkerPlan plan)

This is the base method for the task scheduler to invoke the appropriate task schedulers either "batch" or "streaming" based on the task type.

Specified by:

schedule in interface ITaskScheduler

Parameters:

graph - graph

plan - worker plan

Returns:

the task schedule

schedule

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

This is the base method for the task scheduler to invoke the appropriate task schedulers either "batch" or "streaming" based on the task type.