Uses of Class
edu.snu.coral.common.ir.edge.IREdge

Packages that use IREdge

Package	Description
edu.snu.coral.common.ir.edge
edu.snu.coral.common.ir.executionproperty
edu.snu.coral.common.ir.vertex
edu.snu.coral.compiler.backend
edu.snu.coral.compiler.backend.coral
edu.snu.coral.compiler.frontend.beam
edu.snu.coral.compiler.frontend.spark.core.java
edu.snu.coral.compiler.optimizer
edu.snu.coral.compiler.optimizer.pass.compiletime.annotating
edu.snu.coral.compiler.optimizer.pass.compiletime.composite
edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping
edu.snu.coral.runtime.common.plan.physical
edu.snu.coral.runtime.common.plan.stage

Uses of IREdge in edu.snu.coral.common.ir.edge

Methods in edu.snu.coral.common.ir.edge that return IREdge

Modifier and Type	Method and Description
IREdge	IREdge.setProperty(ExecutionProperty<?> executionProperty) Set an executionProperty of the IREdge.

Methods in edu.snu.coral.common.ir.edge with parameters of type IREdge

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

Uses of IREdge in edu.snu.coral.common.ir.executionproperty

Methods in edu.snu.coral.common.ir.executionproperty with parameters of type IREdge

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

Uses of IREdge in edu.snu.coral.common.ir.vertex

Methods in edu.snu.coral.common.ir.vertex that return IREdge

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

Methods in edu.snu.coral.common.ir.vertex that return types with arguments of type IREdge

Modifier and Type	Method and Description
DAGBuilder<IRVertex,IREdge>	LoopVertex.getBuilder()
DAG<IRVertex,IREdge>	LoopVertex.getDAG()
Map<IRVertex,Set<IREdge>>	LoopVertex.getDagIncomingEdges()
Map<IRVertex,Set<IREdge>>	LoopVertex.getDagOutgoingEdges()
DAG<IRVertex,IREdge>	MetricCollectionBarrierVertex.getDAGSnapshot() Access the DAG snapshot when triggering dynamic optimization.
Map<IRVertex,Set<IREdge>>	LoopVertex.getIterativeIncomingEdges()
Map<IRVertex,Set<IREdge>>	LoopVertex.getNonIterativeIncomingEdges()

Methods in edu.snu.coral.common.ir.vertex with parameters of type IREdge

Modifier and Type	Method and 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.getEdgeWithLoop(IREdge edgeWithInternalVertex)
void	LoopVertex.mapEdgeWithLoop(IREdge edgeWithLoop, IREdge edgeWithInternalVertex) Maps an edge from/to loop with the corresponding edge from/to internal vertex.

Method parameters in edu.snu.coral.common.ir.vertex with type arguments of type IREdge

Modifier and Type	Method and Description
void	MetricCollectionBarrierVertex.setDAGSnapshot(DAG<IRVertex,IREdge> dag) This is to set the DAG snapshot at the end of the DataSkewCompositePass.
LoopVertex	LoopVertex.unRollIteration(DAGBuilder<IRVertex,IREdge> dagBuilder) Method for unrolling an iteration of the LoopVertex.

Uses of IREdge in edu.snu.coral.compiler.backend

Method parameters in edu.snu.coral.compiler.backend with type arguments of type IREdge

Modifier and Type	Method and Description
Plan	Backend.compile(DAG<IRVertex,IREdge> dag) Compiles a DAG to a physical execution plan.

Uses of IREdge in edu.snu.coral.compiler.backend.coral

Method parameters in edu.snu.coral.compiler.backend.coral with type arguments of type IREdge

Modifier and Type	Method and Description
PhysicalPlan	CoralBackend.compile(DAG<IRVertex,IREdge> irDAG) Compiles an IR DAG into a PhysicalPlan to be submitted to Runtime.
PhysicalPlan	CoralBackend.compile(DAG<IRVertex,IREdge> irDAG, PhysicalPlanGenerator physicalPlanGenerator) Compiles an IR DAG into a PhysicalPlan to be submitted to Runtime.

Uses of IREdge in edu.snu.coral.compiler.frontend.beam

Constructor parameters in edu.snu.coral.compiler.frontend.beam with type arguments of type IREdge

Constructor and Description
CoralPipelineVisitor(DAGBuilder<IRVertex,IREdge> builder, org.apache.beam.sdk.options.PipelineOptions options) Constructor of the BEAM Visitor.

Uses of IREdge in edu.snu.coral.compiler.frontend.spark.core.java

Method parameters in edu.snu.coral.compiler.frontend.spark.core.java with type arguments of type IREdge

Modifier and Type	Method and Description
static <T> List<T>	SparkFrontendUtils.collect(DAG<IRVertex,IREdge> dag, Stack<LoopVertex> loopVertexStack, IRVertex lastVertex, org.apache.spark.serializer.Serializer serializer) Collect data by running the DAG.

Uses of IREdge in edu.snu.coral.compiler.optimizer

Methods in edu.snu.coral.compiler.optimizer that return types with arguments of type IREdge

Modifier and Type	Method and Description
static DAG<IRVertex,IREdge>	CompiletimeOptimizer.optimize(DAG<IRVertex,IREdge> dag, Policy optimizationPolicy, String dagDirectory) Optimize function.

Method parameters in edu.snu.coral.compiler.optimizer with type arguments of type IREdge

Modifier and Type	Method and Description
static DAG<IRVertex,IREdge>	CompiletimeOptimizer.optimize(DAG<IRVertex,IREdge> dag, Policy optimizationPolicy, String dagDirectory) Optimize function.

Uses of IREdge in edu.snu.coral.compiler.optimizer.pass.compiletime.annotating

Methods in edu.snu.coral.compiler.optimizer.pass.compiletime.annotating that return types with arguments of type IREdge

Modifier and Type	Method and Description
DAG<IRVertex,IREdge>	DisaggregationEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewEdgeMetricCollectionPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DefaultEdgeUsedDataHandlingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DefaultStagePartitioningPass.apply(DAG<IRVertex,IREdge> irDAG)
DAG<IRVertex,IREdge>	SailfishEdgeUsedDataHandlingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	ScheduleGroupPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	CompressionPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	PadoVertexExecutorPlacementPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewVertexPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	ShuffleEdgePushPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DefaultParallelismPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	ReviseInterStageEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	SailfishEdgeDataFlowModelPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewEdgePartitionerPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	PadoEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	PadoEdgeDataFlowModelPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	SailfishEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)

Method parameters in edu.snu.coral.compiler.optimizer.pass.compiletime.annotating with type arguments of type IREdge

Modifier and Type	Method and Description
DAG<IRVertex,IREdge>	DisaggregationEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewEdgeMetricCollectionPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DefaultEdgeUsedDataHandlingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DefaultStagePartitioningPass.apply(DAG<IRVertex,IREdge> irDAG)
DAG<IRVertex,IREdge>	SailfishEdgeUsedDataHandlingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	ScheduleGroupPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	CompressionPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	PadoVertexExecutorPlacementPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewVertexPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	ShuffleEdgePushPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DefaultParallelismPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	ReviseInterStageEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	SailfishEdgeDataFlowModelPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewEdgePartitionerPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	PadoEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	PadoEdgeDataFlowModelPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	SailfishEdgeDataStorePass.apply(DAG<IRVertex,IREdge> dag)

Uses of IREdge in edu.snu.coral.compiler.optimizer.pass.compiletime.composite

Methods in edu.snu.coral.compiler.optimizer.pass.compiletime.composite that return types with arguments of type IREdge

Modifier and Type	Method and Description
DAG<IRVertex,IREdge>	CompositePass.apply(DAG<IRVertex,IREdge> irVertexIREdgeDAG)

Method parameters in edu.snu.coral.compiler.optimizer.pass.compiletime.composite with type arguments of type IREdge

Modifier and Type	Method and Description
DAG<IRVertex,IREdge>	CompositePass.apply(DAG<IRVertex,IREdge> irVertexIREdgeDAG)

Uses of IREdge in edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping

Methods in edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping that return types with arguments of type IREdge

Modifier and Type	Method and Description
DAG<IRVertex,IREdge>	LoopUnrollingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewReshapingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	LoopOptimizations.LoopFusionPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	LoopOptimizations.LoopInvariantCodeMotionPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	SailfishRelayReshapingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	CommonSubexpressionEliminationPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	LoopExtractionPass.apply(DAG<IRVertex,IREdge> dag)

Method parameters in edu.snu.coral.compiler.optimizer.pass.compiletime.reshaping with type arguments of type IREdge

Modifier and Type	Method and Description
DAG<IRVertex,IREdge>	LoopUnrollingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	DataSkewReshapingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	LoopOptimizations.LoopFusionPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	LoopOptimizations.LoopInvariantCodeMotionPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	SailfishRelayReshapingPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	CommonSubexpressionEliminationPass.apply(DAG<IRVertex,IREdge> dag)
DAG<IRVertex,IREdge>	LoopExtractionPass.apply(DAG<IRVertex,IREdge> dag)

Uses of IREdge in edu.snu.coral.runtime.common.plan.physical

Method parameters in edu.snu.coral.runtime.common.plan.physical with type arguments of type IREdge

Modifier and Type	Method and Description
DAG<PhysicalStage,PhysicalStageEdge>	PhysicalPlanGenerator.apply(DAG<IRVertex,IREdge> irDAG) Generates the PhysicalPlan to be executed.
DAG<Stage,StageEdge>	PhysicalPlanGenerator.stagePartitionIrDAG(DAG<IRVertex,IREdge> irDAG) We take the stage-partitioned DAG and create actual stage and stage edge objects to create a DAG of stages.

Uses of IREdge in edu.snu.coral.runtime.common.plan.stage

Methods in edu.snu.coral.runtime.common.plan.stage that return types with arguments of type IREdge

Modifier and Type	Method and Description
DAG<IRVertex,IREdge>	Stage.getStageInternalDAG()

Methods in edu.snu.coral.runtime.common.plan.stage with parameters of type IREdge

Modifier and Type	Method and Description
StageBuilder	StageBuilder.connectInternalVertices(IREdge edge) Connects two IRVertex in this stage.

Constructor parameters in edu.snu.coral.runtime.common.plan.stage with type arguments of type IREdge

Constructor and Description
Stage(String stageId, DAG<IRVertex,IREdge> stageInternalDAG, int scheduleGroupIndex) Constructor.