Uses of Class
org.apache.nemo.runtime.common.plan.Stage
-
Packages that use Stage Package Description org.apache.nemo.runtime.common.metric org.apache.nemo.runtime.common.plan -
-
Uses of Stage in org.apache.nemo.runtime.common.metric
Method parameters in org.apache.nemo.runtime.common.metric with type arguments of type Stage Modifier and Type Method Description void
JobMetric. setStageDAG(DAG<Stage,StageEdge> dag)
Setter for the stage DAG.Constructors in org.apache.nemo.runtime.common.metric with parameters of type Stage Constructor Description StageMetric(Stage stage)
-
Uses of Stage in org.apache.nemo.runtime.common.plan
Methods in org.apache.nemo.runtime.common.plan that return types with arguments of type Stage Modifier and Type Method Description DAG<Stage,StageEdge>
PhysicalPlanGenerator. apply(IRDAG irDAG)
Generates thePhysicalPlan
to be executed.DAG<Stage,StageEdge>
PhysicalPlan. getStageDAG()
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.Constructors in org.apache.nemo.runtime.common.plan with parameters of type Stage Constructor Description StageEdge(java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties, IRVertex srcVertex, IRVertex dstVertex, Stage srcStage, Stage dstStage)
Constructor.Constructor parameters in org.apache.nemo.runtime.common.plan with type arguments of type Stage Constructor Description PhysicalPlan(java.lang.String id, DAG<Stage,StageEdge> stageDAG)
Constructor.
-