edu.snu.coral.runtime.common.plan.physical

Class ScheduledTaskGroup

java.lang.Object

edu.snu.coral.runtime.common.plan.physical.ScheduledTaskGroup

All Implemented Interfaces:

Serializable

public final class ScheduledTaskGroup
extends Object
implements Serializable

A ScheduledTaskGroup is a grouping of Task that belong to a stage. Executors receive units of ScheduledTaskGroups during job execution, and thus the resource type of all tasks of a ScheduledTaskGroup must be identical. A stage contains a list of IDs of TaskGroups whose length corresponds to stage/operator parallelism. This class includes all information which will be required from the executor after scheduled, including the (serialized) DAG of Tasks, the incoming/outgoing edges to/from the stage the TaskGroup belongs to, and so on.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ScheduledTaskGroup(String jobId, byte[] serializedTaskGroupDag, String taskGroupId, List<PhysicalStageEdge> taskGroupIncomingEdges, List<PhysicalStageEdge> taskGroupOutgoingEdges, int attemptIdx, String containerType) Constructor.

Method Summary

Modifier and Type	Method and Description
int	getAttemptIdx()
String	getContainerType()
String	getJobId()
byte[]	getSerializedTaskGroupDag()
String	getTaskGroupId()
int	getTaskGroupIdx()
List<PhysicalStageEdge>	getTaskGroupIncomingEdges()
List<PhysicalStageEdge>	getTaskGroupOutgoingEdges()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledTaskGroup

public ScheduledTaskGroup(String jobId,
                          byte[] serializedTaskGroupDag,
                          String taskGroupId,
                          List<PhysicalStageEdge> taskGroupIncomingEdges,
                          List<PhysicalStageEdge> taskGroupOutgoingEdges,
                          int attemptIdx,
                          String containerType)

Constructor.

Parameters:

jobId - the id of the job.

serializedTaskGroupDag - the serialized DAG of the task group.

taskGroupId - the ID of the scheduled task group.

taskGroupIncomingEdges - the incoming edges of the task group.

taskGroupOutgoingEdges - the outgoing edges of the task group.

attemptIdx - the attempt index.

containerType - the type of container to execute the task group on.

Method Detail

getJobId

public String getJobId()

Returns:

the id of the job.

getSerializedTaskGroupDag

public byte[] getSerializedTaskGroupDag()

Returns:

the serialized DAG of the task group.

getTaskGroupId

public String getTaskGroupId()

Returns:

the ID of the scheduled task group.

getTaskGroupIdx

public int getTaskGroupIdx()

Returns:

the idx of the scheduled task group.

getTaskGroupIncomingEdges

public List<PhysicalStageEdge> getTaskGroupIncomingEdges()

Returns:

the incoming edges of the taskGroup.

getTaskGroupOutgoingEdges

public List<PhysicalStageEdge> getTaskGroupOutgoingEdges()

Returns:

the outgoing edges of the taskGroup.

getAttemptIdx

public int getAttemptIdx()

Returns:

the attempt index.

getContainerType

public String getContainerType()

Returns:

the type of container to execute the task group on.