edu.iu.dsc.tws.tsched.streaming.firstfit

Class FirstFitStreamingTaskScheduler

java.lang.Object

edu.iu.dsc.tws.tsched.streaming.firstfit.FirstFitStreamingTaskScheduler

All Implemented Interfaces:

ITaskScheduler

public class FirstFitStreamingTaskScheduler
extends java.lang.Object
implements ITaskScheduler

This class allocate the task instances into the container in a heuristic manner. It first sort the task instances based on the required ram configuration. Also, it provides the support of heterogeneous container and task instance allocation.

For example, if there are two tasks with parallelism value of 2, 1st task -> instance 0 will go to container 0, 1st task -> instance 1 will go to container 0, 2nd task -> instance 0 will go to container 0 (if the total task instance required values doesn't reach the maximum size of container 0. If the container has reached its maximum limit then it will allocate the 2nd task -> instance 1 will go to container 1.

Constructor Summary

Constructors

Constructor and Description
FirstFitStreamingTaskScheduler()

Method Summary

Modifier and Type	Method and Description
void	initialize(Config cfg) This method initialize the config values received from the user and assign the default task instance value and container instance values.
void	initialize(Config cfg, int workerId) Initialize with the worker id
TaskSchedulePlan	schedule(ComputeGraph computeGraph, WorkerPlan workerPlan) This is the base method for the first fit task scheduling.

Methods inherited from class java.lang.Object

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

Constructor Detail

FirstFitStreamingTaskScheduler

public FirstFitStreamingTaskScheduler()

Method Detail

initialize

public void initialize(Config cfg)

This method initialize the config values received from the user and assign the default task instance value and container instance values.

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 for the first fit task scheduling. It invokes the taskscheduleplan builder to allocate the task instances into the containers.

Specified by:

schedule in interface ITaskScheduler

Parameters:

computeGraph - graph

workerPlan - worker plan

Returns:

the task schedule