edu.snu.coral.compiler.optimizer.pass.compiletime.composite

Class DataSkewCompositePass

java.lang.Object

edu.snu.coral.compiler.optimizer.pass.compiletime.composite.CompositePass

edu.snu.coral.compiler.optimizer.pass.compiletime.composite.DataSkewCompositePass

All Implemented Interfaces:

CompileTimePass, Serializable, Function<DAG<IRVertex,IREdge>,DAG<IRVertex,IREdge>>

public final class DataSkewCompositePass
extends CompositePass

Pass to modify the DAG for a job to perform data skew. It adds a MetricCollectionBarrierVertex before Shuffle edges, to make a barrier before it, and to use the metrics to repartition the skewed data. NOTE: we currently put the DataSkewCompositePass at the end of the list for each policies, as it needs to take a snapshot at the end of the pass. This could be prevented by modifying other passes to take the snapshot of the DAG at the end of each passes for metricCollectionVertices.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DataSkewCompositePass() Default constructor.

Method Summary

Methods inherited from class edu.snu.coral.compiler.optimizer.pass.compiletime.composite.CompositePass

apply, getPassList, getPrerequisiteExecutionProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

DataSkewCompositePass

public DataSkewCompositePass()

Default constructor.