Uses of Class
org.apache.nemo.common.dag.DAG

Packages that use DAG

Package	Description
org.apache.nemo.common.dag
org.apache.nemo.common.ir
org.apache.nemo.common.ir.vertex
org.apache.nemo.common.ir.vertex.utility
org.apache.nemo.runtime.common.metric
org.apache.nemo.runtime.common.plan
org.apache.nemo.runtime.executor.task

Uses of DAG in org.apache.nemo.common.dag

Methods in org.apache.nemo.common.dag that return DAG

Modifier and Type	Method	Description
DAG<V,E>	DAGBuilder.build()	Build the DAG.
DAG<V,E>	DAGBuilder.buildWithoutSourceCheck()	Build the DAG without source check.
DAG<V,E>	DAGBuilder.buildWithoutSourceSinkCheck()	Build the DAG without source and sink check.

Methods in org.apache.nemo.common.dag with parameters of type DAG

Modifier and Type	Method	Description
DAGBuilder<V,E>	DAGBuilder.addVertex(V v, DAG<V,E> dag)	Add vertex to the builder, using the information from the given DAG.

Constructors in org.apache.nemo.common.dag with parameters of type DAG

Constructor	Description
DAGBuilder(DAG<V,E> dag)	Constructor of DAGBuilder with a DAG to start from.

Uses of DAG in org.apache.nemo.common.ir

Methods in org.apache.nemo.common.ir with parameters of type DAG

Modifier and Type	Method	Description
IRDAGChecker.CheckerResult	IRDAGChecker.GlobalDAGChecker.check(DAG<IRVertex,IREdge> irdag)
IRDAGChecker.CheckerResult	IRDAGChecker.doCheck(DAG<IRVertex,IREdge> underlyingDAG)	Applies all of the checkers on the DAG.

Method parameters in org.apache.nemo.common.ir with type arguments of type DAG

Modifier and Type	Method	Description
void	IRDAG.reshapeUnsafely(java.util.function.Function<DAG<IRVertex,IREdge>,DAG<IRVertex,IREdge>> unsafeReshapingFunction)	Reshape unsafely, without guarantees on preserving application semantics.
void	IRDAG.reshapeUnsafely(java.util.function.Function<DAG<IRVertex,IREdge>,DAG<IRVertex,IREdge>> unsafeReshapingFunction)	Reshape unsafely, without guarantees on preserving application semantics.

Constructors in org.apache.nemo.common.ir with parameters of type DAG

Constructor	Description
IRDAG(DAG<IRVertex,IREdge> originalUserApplicationDAG)

Uses of DAG in org.apache.nemo.common.ir.vertex

Methods in org.apache.nemo.common.ir.vertex that return DAG

Modifier and Type	Method	Description
DAG<IRVertex,IREdge>	LoopVertex.getDAG()

Uses of DAG in org.apache.nemo.common.ir.vertex.utility

Methods in org.apache.nemo.common.ir.vertex.utility with parameters of type DAG

Modifier and Type	Method	Description
java.util.Set<IREdge>	TaskSizeSplitterVertex.getEdgesFromOriginalToOutside(DAG<IRVertex,IREdge> dag)	Get edges which come from original vertices to outer destinations by observing the dag.
java.util.Set<IREdge>	TaskSizeSplitterVertex.getEdgesFromOutsideToOriginal(DAG<IRVertex,IREdge> dag)	Get edges which come to original vertices from outer sources by observing the dag.
java.util.Set<IREdge>	TaskSizeSplitterVertex.getEdgesFromOutsideToSplitter(DAG<IRVertex,IREdge> dag)	Get edges which come to splitter from outside sources.
java.util.Set<IREdge>	TaskSizeSplitterVertex.getEdgesFromSplitterToOutside(DAG<IRVertex,IREdge> dag)	Get edges which come out from splitter to outside destinations.

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

Methods in org.apache.nemo.runtime.common.metric with parameters of type DAG

Modifier and Type	Method	Description
void	JobMetric.setStageDAG(DAG<Stage,StageEdge> dag)	Setter for the stage DAG.

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

Methods in org.apache.nemo.runtime.common.plan that return DAG

Modifier and Type	Method	Description
DAG<Stage,StageEdge>	PhysicalPlanGenerator.apply(IRDAG irDAG)	Generates the PhysicalPlan to be executed.
DAG<IRVertex,RuntimeEdge<IRVertex>>	Stage.getIRDAG()
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 DAG

Constructor	Description
PhysicalPlan(java.lang.String id, DAG<Stage,StageEdge> stageDAG)	Constructor.
Stage(java.lang.String stageId, java.util.List<java.lang.Integer> taskIndices, DAG<IRVertex,RuntimeEdge<IRVertex>> irDag, ExecutionPropertyMap<VertexExecutionProperty> executionProperties, java.util.List<java.util.Map<java.lang.String,Readable>> vertexIdToReadables)	Constructor.

Uses of DAG in org.apache.nemo.runtime.executor.task

Constructors in org.apache.nemo.runtime.executor.task with parameters of type DAG

Constructor	Description
TaskExecutor(Task task, DAG<IRVertex,RuntimeEdge<IRVertex>> irVertexDag, TaskStateManager taskStateManager, IntermediateDataIOFactory intermediateDataIOFactory, BroadcastManagerWorker broadcastManagerWorker, MetricMessageSender metricMessageSender, PersistentConnectionToMasterMap persistentConnectionToMasterMap, int latencyMarkPeriod)	Constructor.