Uses of Class
edu.snu.coral.runtime.common.plan.RuntimeEdge

Packages that use RuntimeEdge

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

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

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

Modifier and Type	Class and Description
class	PhysicalStageEdge Contains information stage boundary StageEdge.

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

Modifier and Type	Method and Description
DAG<Task,RuntimeEdge<Task>>	PhysicalStage.getTaskGroupDag()

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

Constructor and Description
PhysicalStage(String stageId, DAG<Task,RuntimeEdge<Task>> taskGroupDag, int parallelism, int scheduleGroupIndex, String containerType) Constructor.

Uses of RuntimeEdge in edu.snu.coral.runtime.common.plan.stage

Subclasses of RuntimeEdge in edu.snu.coral.runtime.common.plan.stage

Modifier and Type	Class and Description
class	StageEdge Stage Edge.

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

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

Constructor and Description
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)

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

Methods in edu.snu.coral.runtime.executor.datatransfer that return RuntimeEdge

Modifier and Type	Method and Description
RuntimeEdge	InputReader.getRuntimeEdge()

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

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

Constructors in edu.snu.coral.runtime.executor.datatransfer with parameters of type RuntimeEdge

Constructor and Description
InputReader(int dstTaskIndex, IRVertex srcVertex, RuntimeEdge runtimeEdge, BlockManagerWorker blockManagerWorker)
OutputWriter(int hashRangeMultiplier, int srcTaskIdx, String srcRuntimeVertexId, IRVertex dstIrVertex, RuntimeEdge<?> runtimeEdge, BlockManagerWorker blockManagerWorker)