Uses of Class org.apache.nemo.runtime.common.plan.StageEdge (Nemo Project 0.4 API)

Packages that use StageEdge
Package	Description
org.apache.nemo.compiler.backend.nemo
org.apache.nemo.compiler.backend.nemo.prophet
org.apache.nemo.runtime.common.metric
org.apache.nemo.runtime.common.plan

Uses of StageEdge in org.apache.nemo.compiler.backend.nemo

Method parameters in org.apache.nemo.compiler.backend.nemo with type arguments of type StageEdge
Modifier and Type	Method	Description
`void`	NemoPlanRewriter.`accumulate(int messageId, java.util.Set<StageEdge> targetEdges, java.lang.Object data)`	Accumulate the data needed in Plan Rewrite.

Uses of StageEdge in org.apache.nemo.compiler.backend.nemo.prophet

Constructor parameters in org.apache.nemo.compiler.backend.nemo.prophet with type arguments of type StageEdge
Constructor	Description
`ParallelismProphet(IRDAG irdag, PhysicalPlan physicalPlan, SimulationScheduler simulationScheduler, PhysicalPlanGenerator physicalPlanGenerator, java.util.Set<StageEdge> edgesToOptimize)`	Default constructor for ParallelismProphet.

Uses of StageEdge in org.apache.nemo.runtime.common.metric

Method parameters in org.apache.nemo.runtime.common.metric with type arguments of type StageEdge
Modifier and Type	Method	Description
`void`	JobMetric.`setStageDAG(DAG<Stage,StageEdge> dag)`	Setter for the stage DAG.

Uses of StageEdge in org.apache.nemo.runtime.common.plan

Methods in org.apache.nemo.runtime.common.plan that return types with arguments of type StageEdge
Modifier and Type	Method	Description
`DAG<Stage,StageEdge>`	PhysicalPlanGenerator.`apply(IRDAG irDAG)`	Generates the `PhysicalPlan` to be executed.
`DAG<Stage,StageEdge>`	PhysicalPlan.`getStageDAG()`
`java.util.List<StageEdge>`	Task.`getTaskIncomingEdges()`
`java.util.List<StageEdge>`	Task.`getTaskOutgoingEdges()`
`DAG<Stage,StageEdge>`	PhysicalPlanGenerator.`stagePartitionIrDAG(IRDAG irDAG)`	We take the stage-partitioned DAG and create actual stage and stage edge objects to create a DAG of stages.

Methods in org.apache.nemo.runtime.common.plan with parameters of type StageEdge
Modifier and Type	Method	Description
`java.lang.Boolean`	StageEdge.`hasSameItineraryAs(StageEdge edge)`

Method parameters in org.apache.nemo.runtime.common.plan with type arguments of type StageEdge
Modifier and Type	Method	Description
`void`	PlanRewriter.`accumulate(int messageId, java.util.Set<StageEdge> targetEdges, java.lang.Object data)`

Constructor parameters in org.apache.nemo.runtime.common.plan with type arguments of type StageEdge
Constructor	Description
`PhysicalPlan(java.lang.String id, DAG<Stage,StageEdge> stageDAG)`	Constructor.
`Task(java.lang.String planId, java.lang.String taskId, ExecutionPropertyMap<VertexExecutionProperty> executionProperties, byte[] serializedIRDag, java.util.List<StageEdge> taskIncomingEdges, java.util.List<StageEdge> taskOutgoingEdges, java.util.Map<java.lang.String,Readable> irVertexIdToReadable)`	Constructor.