Uses of Class
org.apache.nemo.common.ir.edge.IREdge

Packages that use IREdge

Package	Description
org.apache.nemo.common
org.apache.nemo.common.ir
org.apache.nemo.common.ir.edge
org.apache.nemo.common.ir.executionproperty
org.apache.nemo.common.ir.vertex
org.apache.nemo.common.ir.vertex.utility
org.apache.nemo.common.test
org.apache.nemo.compiler.optimizer.pass.runtime

Uses of IREdge in org.apache.nemo.common

Methods in org.apache.nemo.common that return IREdge

Modifier and Type	Method	Description
static IREdge	Util.cloneEdge(CommunicationPatternProperty.Value commPattern, IREdge edgeToClone, IRVertex newSrc, IRVertex newDst)	Creates a new edge with several execution properties same as the given edge.
static IREdge	Util.cloneEdge(IREdge edgeToClone, IRVertex newSrc, IRVertex newDst)
static IREdge	Util.createControlEdge(IRVertex src, IRVertex dst)	A control edge enforces an execution ordering between the source vertex and the destination vertex.

Methods in org.apache.nemo.common with parameters of type IREdge

Modifier and Type	Method	Description
static IREdge	Util.cloneEdge(CommunicationPatternProperty.Value commPattern, IREdge edgeToClone, IRVertex newSrc, IRVertex newDst)	Creates a new edge with several execution properties same as the given edge.
static IREdge	Util.cloneEdge(IREdge edgeToClone, IRVertex newSrc, IRVertex newDst)
static boolean	Util.isControlEdge(IREdge edge)

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

Modifier and Type	Method	Description
static java.lang.String	Util.stringifyIREdgeIds(java.util.Collection<IREdge> edges)

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

Methods in org.apache.nemo.common.ir that return IREdge

Modifier and Type	Method	Description
IREdge	IRDAG.getEdgeBetween(java.lang.String srcVertexId, java.lang.String dstVertexId)
IREdge	IRDAG.getEdgeById(java.lang.String id)

Methods in org.apache.nemo.common.ir that return types with arguments of type IREdge

Modifier and Type	Method	Description
java.util.List<IREdge>	IRDAG.getEdges()
java.util.List<IREdge>	IRDAG.getIncomingEdgesOf(java.lang.String vertexId)
java.util.List<IREdge>	IRDAG.getIncomingEdgesOf(IRVertex v)
java.util.List<IREdge>	IRDAG.getOutgoingEdgesOf(java.lang.String vertexId)
java.util.List<IREdge>	IRDAG.getOutgoingEdgesOf(IRVertex v)

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

Modifier and Type	Method	Description
void	IRDAG.insert(RelayVertex relayVertex, IREdge edgeToStreamize)	Inserts a new vertex that streams data.
void	IRDAG.insert(SignalVertex toInsert, IREdge edgeToOptimize)	Inserts new vertex which calls for runtime pass.

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

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.
void	IRDAG.insert(MessageGeneratorVertex messageGeneratorVertex, MessageAggregatorVertex messageAggregatorVertex, EncoderProperty triggerOutputEncoder, DecoderProperty triggerOutputDecoder, java.util.Set<IREdge> edgesToGetStatisticsOf, java.util.Set<IREdge> edgesToOptimize)	Inserts a new vertex that analyzes intermediate data, and triggers a dynamic optimization.
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.

Constructor parameters in org.apache.nemo.common.ir with type arguments of type IREdge

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

Uses of IREdge in org.apache.nemo.common.ir.edge

Methods in org.apache.nemo.common.ir.edge that return IREdge

Modifier and Type	Method	Description
IREdge	IREdge.setProperty(EdgeExecutionProperty<?> executionProperty)	Set an executionProperty of the IREdge.
IREdge	IREdge.setPropertyPermanently(EdgeExecutionProperty<?> executionProperty)	Set an executionProperty of the IREdge, permanently.

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

Modifier and Type	Method	Description
void	IREdge.copyExecutionPropertiesTo(IREdge thatEdge)	Static function to copy executionProperties from an edge to the other.
java.lang.Boolean	IREdge.hasSameItineraryAs(IREdge edge)

Uses of IREdge in org.apache.nemo.common.ir.executionproperty

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

Modifier and Type	Method	Description
static ExecutionPropertyMap<EdgeExecutionProperty>	ExecutionPropertyMap.of(IREdge irEdge, CommunicationPatternProperty.Value commPattern)	Static initializer for irEdges.

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

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

Modifier and Type	Method	Description
IREdge	LoopVertex.getEdgeWithInternalVertex(IREdge edgeWithLoop)
IREdge	LoopVertex.getEdgeWithLoop(IREdge edgeWithInternalVertex)

Methods in org.apache.nemo.common.ir.vertex that return types with arguments of type IREdge

Modifier and Type	Method	Description
DAGBuilder<IRVertex,IREdge>	LoopVertex.getBuilder()
DAG<IRVertex,IREdge>	LoopVertex.getDAG()
java.util.Map<IRVertex,java.util.Set<IREdge>>	LoopVertex.getDagIncomingEdges()
java.util.Map<IRVertex,java.util.Set<IREdge>>	LoopVertex.getDagOutgoingEdges()
java.util.Map<IREdge,IREdge>	LoopVertex.getEdgeWithInternalVertexToEdgeWithLoop()	Getter method for edgeWithInternalVertexToEdgeWithLoop.
java.util.Map<IREdge,IREdge>	LoopVertex.getEdgeWithInternalVertexToEdgeWithLoop()	Getter method for edgeWithInternalVertexToEdgeWithLoop.
java.util.Map<IREdge,IREdge>	LoopVertex.getEdgeWithLoopToEdgeWithInternalVertex()	Getter method for edgeWithLoopToEdgeWithInternalVertex.
java.util.Map<IREdge,IREdge>	LoopVertex.getEdgeWithLoopToEdgeWithInternalVertex()	Getter method for edgeWithLoopToEdgeWithInternalVertex.
java.util.Map<IRVertex,java.util.Set<IREdge>>	LoopVertex.getIterativeIncomingEdges()
java.util.Map<IRVertex,java.util.Set<IREdge>>	LoopVertex.getNonIterativeIncomingEdges()

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

Modifier and Type	Method	Description
void	LoopVertex.addDagIncomingEdge(IREdge edge)	Adds the incoming edge of the contained DAG.
void	LoopVertex.addDagOutgoingEdge(IREdge edge)	Adds and outgoing edge of the contained DAG.
void	LoopVertex.addIterativeIncomingEdge(IREdge edge)	Adds an iterative incoming edge, from the previous iteration, but connection internally.
void	LoopVertex.addNonIterativeIncomingEdge(IREdge edge)	Adds a non-iterative incoming edge, from outside the previous iteration.
IREdge	LoopVertex.getEdgeWithInternalVertex(IREdge edgeWithLoop)
IREdge	LoopVertex.getEdgeWithLoop(IREdge edgeWithInternalVertex)
void	LoopVertex.mapEdgeWithLoop(IREdge edgeWithLoop, IREdge edgeWithInternalVertex)	Maps an edge from/to loop with the corresponding edge from/to internal vertex.
void	LoopVertex.removeDagIncomingEdge(IREdge edge)	Removes the incoming edge of the contained DAG.
void	LoopVertex.removeDagOutgoingEdge(IREdge edge)	Removes a dag outgoing edge.
void	LoopVertex.removeIterativeIncomingEdge(IREdge edge)	Remove an iterative incoming edge.
void	LoopVertex.removeNonIterativeIncomingEdge(IREdge edge)	Removes non iterative incoming edge.

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

Modifier and Type	Method	Description
LoopVertex	LoopVertex.unRollIteration(DAGBuilder<IRVertex,IREdge> dagBuilder)	Method for unrolling an iteration of the LoopVertex.

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

Methods in org.apache.nemo.common.ir.vertex.utility that return IREdge

Modifier and Type	Method	Description
IREdge	SamplingVertex.getCloneOfOriginalEdge(IREdge originalEdge)	Obtains a clone of an original edge that is attached to this sampling vertex.

Methods in org.apache.nemo.common.ir.vertex.utility that return types with arguments of type IREdge

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.

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

Modifier and Type	Method	Description
IREdge	SamplingVertex.getCloneOfOriginalEdge(IREdge originalEdge)	Obtains a clone of an original edge that is attached to this sampling vertex.

Method parameters in org.apache.nemo.common.ir.vertex.utility with type arguments of type IREdge

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.
TaskSizeSplitterVertex	TaskSizeSplitterVertex.unRollIteration(DAGBuilder<IRVertex,IREdge> dagBuilder)	Need to be careful about Signal Vertex, because they do not appear in the last iteration.

Uses of IREdge in org.apache.nemo.common.test

Methods in org.apache.nemo.common.test that return IREdge

Modifier and Type	Method	Description
static IREdge	EmptyComponents.newDummyShuffleEdge(IRVertex src, IRVertex dst)

Uses of IREdge in org.apache.nemo.compiler.optimizer.pass.runtime

Methods in org.apache.nemo.compiler.optimizer.pass.runtime that return types with arguments of type IREdge

Modifier and Type	Method	Description
java.util.Set<IREdge>	Message.getExaminedEdges()

Constructor parameters in org.apache.nemo.compiler.optimizer.pass.runtime with type arguments of type IREdge

Constructor	Description
Message(int messageId, java.util.Set<IREdge> edgesToExamine, T value)