edu.iu.dsc.tws.api.compute.schedule

Interface ITaskScheduler

All Known Implementing Classes:

BatchTaskScheduler, DataLocalityBatchTaskScheduler, DataLocalityStreamingTaskScheduler, FirstFitStreamingTaskScheduler, RoundRobinBatchTaskScheduler, RoundRobinTaskScheduler, TaskScheduler, UserDefinedTaskScheduler

public interface ITaskScheduler

This is the main interface for the task scheduler.

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 workerPlan) Schedule the task graph on the worker plan

Method Detail

initialize

void initialize(Config cfg)

Intialize the task scheduler with the configuration

Parameters:

cfg - configuration object

initialize

void initialize(Config cfg,
                int workerId)

Initialize with the worker id

Parameters:

cfg - configuration

workerId - this worker id

schedule

TaskSchedulePlan schedule(ComputeGraph graph,
                          WorkerPlan workerPlan)

Schedule the task graph on the worker plan

Parameters:

graph - graph

workerPlan - worker plan

Returns:

the task schedule