edu.snu.coral.runtime.common

Class RuntimeIdGenerator

java.lang.Object

edu.snu.coral.runtime.common.RuntimeIdGenerator

public final class RuntimeIdGenerator
extends Object

ID Generator.

Method Summary

Modifier and Type	Method and Description
static String	generateBlockId(String runtimeEdgeId, int taskIndex) Generates the ID for a block, whose data is the output of a task.
static String	generateExecutorId() Generates the ID for executor.
static String	generateLogicalTaskId(String irVertexId) Generates the ID for Task.
static long	generateMessageId() Generates the ID for a control message.
static String	generatePhysicalPlanId() Generates the ID for PhysicalPlan.
static String	generatePhysicalTaskId(int index, String logicalTaskId) Generates the ID for Task.
static String	generateResourceSpecId() Generates the ID for a resource specification.
static String	generateRuntimeEdgeId(String irEdgeId) Generates the ID for RuntimeEdge.
static String	generateStageEdgeId(String irEdgeId) Generates the ID for StageEdge.
static String	generateStageId(Integer stageId) Generates the ID for Stage.
static String	generateTaskGroupId(int index, String stageId) Generates the ID for ScheduledTaskGroup.
static int	getIndexFromTaskGroupId(String taskGroupId) Extracts task group index from a task group ID.
static String	getLogicalTaskIdIdFromPhysicalTaskId(String physicalTaskId) Extracts logical task ID from a physical task ID.
static String	getRuntimeEdgeIdFromBlockId(String blockId) Extracts runtime edge ID from a block ID.
static String	getStageIdFromTaskGroupId(String taskGroupId) Extracts stage ID from a task group ID.
static String	getTaskIndexFromBlockId(String blockId) Extracts task index from a block ID.

Methods inherited from class java.lang.Object

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

Method Detail

generatePhysicalPlanId

public static String generatePhysicalPlanId()

Generates the ID for PhysicalPlan.

Returns:

the generated ID

generateStageEdgeId

public static String generateStageEdgeId(String irEdgeId)

Generates the ID for StageEdge.

Parameters:

irEdgeId - .

Returns:

the generated ID

generateRuntimeEdgeId

public static String generateRuntimeEdgeId(String irEdgeId)

Generates the ID for RuntimeEdge.

Parameters:

irEdgeId - .

Returns:

the generated ID

generateStageId

public static String generateStageId(Integer stageId)

Generates the ID for Stage.

Parameters:

stageId - stage ID in numeric form.

Returns:

the generated ID

generateLogicalTaskId

public static String generateLogicalTaskId(String irVertexId)

Generates the ID for Task.

Parameters:

irVertexId - the ID of the IR vertex.

Returns:

the generated ID

generatePhysicalTaskId

public static String generatePhysicalTaskId(int index,
                                            String logicalTaskId)

Generates the ID for Task.

Parameters:

index - the index of the physical task.

logicalTaskId - the logical ID of the task.

Returns:

the generated ID

generateTaskGroupId

public static String generateTaskGroupId(int index,
                                         String stageId)

Generates the ID for ScheduledTaskGroup.

Parameters:

index - the index of this task group.

stageId - the ID of the stage.

Returns:

the generated ID

generateExecutorId

public static String generateExecutorId()

Generates the ID for executor.

Returns:

the generated ID

generateBlockId

public static String generateBlockId(String runtimeEdgeId,
                                     int taskIndex)

Generates the ID for a block, whose data is the output of a task.

Parameters:

runtimeEdgeId - of the block

taskIndex - of the block

Returns:

the generated ID

generateMessageId

public static long generateMessageId()

Generates the ID for a control message.

Returns:

the generated ID

generateResourceSpecId

public static String generateResourceSpecId()

Generates the ID for a resource specification.

Returns:

the generated ID

getRuntimeEdgeIdFromBlockId

public static String getRuntimeEdgeIdFromBlockId(String blockId)

Extracts runtime edge ID from a block ID.

Parameters:

blockId - the block ID to extract.

Returns:

the runtime edge ID.

getTaskIndexFromBlockId

public static String getTaskIndexFromBlockId(String blockId)

Extracts task index from a block ID.

Parameters:

blockId - the block ID to extract.

Returns:

the task index.

getStageIdFromTaskGroupId

public static String getStageIdFromTaskGroupId(String taskGroupId)

Extracts stage ID from a task group ID.

Parameters:

taskGroupId - the task group ID to extract.

Returns:

the stage ID.

getIndexFromTaskGroupId

public static int getIndexFromTaskGroupId(String taskGroupId)

Extracts task group index from a task group ID.

Parameters:

taskGroupId - the task group ID to extract.

Returns:

the index.

getLogicalTaskIdIdFromPhysicalTaskId

public static String getLogicalTaskIdIdFromPhysicalTaskId(String physicalTaskId)

Extracts logical task ID from a physical task ID.

Parameters:

physicalTaskId - the physical task ID to extract.

Returns:

the logical task ID.