edu.iu.dsc.tws.executor.core

Class TaskIdGenerator

java.lang.Object

edu.iu.dsc.tws.executor.core.TaskIdGenerator

public class TaskIdGenerator
extends java.lang.Object

This is a global task id generator depending on the globalTaskId, task index and task name

Field Summary

Fields

Modifier and Type	Field and Description
static int	TASK_OFFSET

Constructor Summary

Constructors

Constructor and Description
TaskIdGenerator()

Method Summary

Modifier and Type	Method and Description
int	generateGlobalTaskId(int taskId, int taskIndex) Generate a unique global task id
java.util.Map<java.lang.Integer,java.lang.Integer>	getGlobalTaskToIndex(Vertex v, int taskId)
java.util.Set<java.lang.Integer>	getTaskIds(Vertex v, int taskId)
java.util.Set<java.lang.Integer>	getTaskIdsOfContainer(WorkerSchedulePlan cPlan)

Methods inherited from class java.lang.Object

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

Field Detail

TASK_OFFSET

public static final int TASK_OFFSET

See Also:

Constant Field Values

Constructor Detail

TaskIdGenerator

public TaskIdGenerator()

Method Detail

generateGlobalTaskId

public int generateGlobalTaskId(int taskId,
                                int taskIndex)

Generate a unique global task id

Parameters:

taskId - task id

taskIndex - task index

Returns:

the global task id

getTaskIds

public java.util.Set<java.lang.Integer> getTaskIds(Vertex v,
                                                   int taskId)

getGlobalTaskToIndex

public java.util.Map<java.lang.Integer,java.lang.Integer> getGlobalTaskToIndex(Vertex v,
                                                                               int taskId)

getTaskIdsOfContainer

public java.util.Set<java.lang.Integer> getTaskIdsOfContainer(WorkerSchedulePlan cPlan)