Uses of Class
edu.snu.coral.runtime.common.plan.physical.Task

Packages that use Task

Package	Description
edu.snu.coral.runtime.common.plan.physical
edu.snu.coral.runtime.executor
edu.snu.coral.runtime.executor.datatransfer

Uses of Task in edu.snu.coral.runtime.common.plan.physical

Subclasses of Task in edu.snu.coral.runtime.common.plan.physical

Modifier and Type	Class and Description
class	BoundedSourceTask<O> BoundedSourceTask.
class	MetricCollectionBarrierTask MetricCollectionBarrierTask.
class	OperatorTask OperatorTask.
class	UnboundedSourceTask UnboundedSourceTask.

Methods in edu.snu.coral.runtime.common.plan.physical that return types with arguments of type Task

Modifier and Type	Method and Description
DAG<Task,RuntimeEdge<Task>>	PhysicalStage.getTaskGroupDag()
DAG<Task,RuntimeEdge<Task>>	PhysicalStage.getTaskGroupDag()
Map<Task,IRVertex>	PhysicalPlanGenerator.getTaskIRVertexMap() Getter for taskIRVertexMap.
Map<Task,IRVertex>	PhysicalPlan.getTaskIRVertexMap()

Methods in edu.snu.coral.runtime.common.plan.physical with parameters of type Task

Modifier and Type	Method and Description
IRVertex	PhysicalPlan.getIRVertexOf(Task task) Get an IR vertex of the given task.

Constructor parameters in edu.snu.coral.runtime.common.plan.physical with type arguments of type Task

Constructor and Description
PhysicalPlan(String id, DAG<PhysicalStage,PhysicalStageEdge> stageDAG, Map<Task,IRVertex> taskIRVertexMap) Constructor.
PhysicalStage(String stageId, DAG<Task,RuntimeEdge<Task>> taskGroupDag, int parallelism, int scheduleGroupIndex, String containerType) Constructor.
PhysicalStage(String stageId, DAG<Task,RuntimeEdge<Task>> taskGroupDag, int parallelism, int scheduleGroupIndex, String containerType) Constructor.

Uses of Task in edu.snu.coral.runtime.executor

Constructor parameters in edu.snu.coral.runtime.executor with type arguments of type Task

Constructor and Description
TaskGroupExecutor(ScheduledTaskGroup scheduledTaskGroup, DAG<Task,RuntimeEdge<Task>> taskGroupDag, TaskGroupStateManager taskGroupStateManager, DataTransferFactory channelFactory)
TaskGroupExecutor(ScheduledTaskGroup scheduledTaskGroup, DAG<Task,RuntimeEdge<Task>> taskGroupDag, TaskGroupStateManager taskGroupStateManager, DataTransferFactory channelFactory)
TaskGroupStateManager(ScheduledTaskGroup scheduledTaskGroup, DAG<Task,RuntimeEdge<Task>> taskGroupDag, String executorId, PersistentConnectionToMasterMap persistentConnectionToMasterMap, MetricMessageSender metricMessageSender)
TaskGroupStateManager(ScheduledTaskGroup scheduledTaskGroup, DAG<Task,RuntimeEdge<Task>> taskGroupDag, String executorId, PersistentConnectionToMasterMap persistentConnectionToMasterMap, MetricMessageSender metricMessageSender)

Uses of Task in edu.snu.coral.runtime.executor.datatransfer

Methods in edu.snu.coral.runtime.executor.datatransfer with parameters of type Task

Modifier and Type	Method and Description
OutputWriter	DataTransferFactory.createLocalWriter(Task srcTask, int srcTaskIdx, RuntimeEdge<?> runtimeEdge) Creates an local OutputWriter between two task in a single task group.
OutputWriter	DataTransferFactory.createWriter(Task srcTask, int srcTaskIdx, IRVertex dstIRVertex, RuntimeEdge<?> runtimeEdge) Creates an OutputWriter between two stages.