Uses of Class
org.apache.nemo.runtime.common.plan.StageEdge
-
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 thePhysicalPlan
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.
-