Uses of Class
org.apache.nemo.common.pass.Pass
-
-
Uses of Pass in org.apache.nemo.common.pass
Methods in org.apache.nemo.common.pass that return Pass Modifier and Type Method Description Pass
Pass. addCondition(java.util.function.Predicate<IRDAG> newCondition)
Add the condition to the existing condition to run the pass. -
Uses of Pass in org.apache.nemo.compiler.optimizer.pass.compiletime
Subclasses of Pass in org.apache.nemo.compiler.optimizer.pass.compiletime Modifier and Type Class Description class
CompileTimePass
Abstract class for compile-time optimization passes that processes the DAG. -
Uses of Pass in org.apache.nemo.compiler.optimizer.pass.compiletime.annotating
Subclasses of Pass in org.apache.nemo.compiler.optimizer.pass.compiletime.annotating Modifier and Type Class Description class
AggressiveSpeculativeCloningPass
Speculative execution.class
AnnotatingPass
A compile-time pass that annotates the IR DAG with execution properties.class
CompressionPass
A pass for applying compression algorithm for data flowing between vertices.class
DefaultDataPersistencePass
Pass for initiating IREdge data persistence ExecutionProperty with default values.class
DefaultDataStorePass
Edge data store pass to process inter-stage memory store edges.class
DefaultEdgeDecoderPass
Pass for initiating IREdge Decoder ExecutionProperty with default dummy coder.class
DefaultEdgeEncoderPass
Pass for initiating IREdge Encoder ExecutionProperty with default dummy coder.class
DefaultParallelismPass
Optimization pass for tagging parallelism execution property.class
DefaultScheduleGroupPass
A pass for assigning each stages in schedule groups.class
DisaggregationEdgeDataStorePass
A pass to support Disaggregated Resources by tagging edges.class
DuplicateEdgeGroupSizePass
A pass for annotate duplicate data for each edge.class
LambdaPass
Lambda Pass.class
LargeShuffleAnnotatingPass
This pass assumes that a RelayVertex was previously inserted to receive each shuffle edge.class
PipeTransferForAllEdgesPass
Annotate 'Pipe' on all edges.class
ResourceLocalityPass
SetsResourceLocalityProperty
.class
ResourceSitePass
Computes and assigns appropriate share of nodes to each irVertex to minimize shuffle time, with respect to bandwidth restrictions of nodes.class
ResourceSlotPass
SetsResourceSlotProperty
.class
ShuffleEdgePushPass
A pass for tagging shuffle edges different from the default ones.class
SkewAnnotatingPass
For each shuffle edge, set the number of partitions to (dstParallelism * HASH_RANGE_MULTIPLIER).class
TransientResourceDataTransferPass
Optimizes IREdges between transient resources and reserved resources.class
TransientResourcePriorityPass
Place valuable computations on reserved resources, and the rest on transient resources.class
UpfrontCloningPass
Set the ClonedScheduling property of source vertices, in an upfront manner.class
XGBoostPass
Pass for applying XGBoost optimizations. -
Uses of Pass in org.apache.nemo.compiler.optimizer.pass.compiletime.composite
Subclasses of Pass in org.apache.nemo.compiler.optimizer.pass.compiletime.composite Modifier and Type Class Description class
CompositePass
A compile-time pass composed of multiple compile-time passes, which each modifies an IR DAG.class
DefaultCompositePass
A series of primitive passes that is applied commonly to all policies.class
LargeShuffleCompositePass
A series of passes to optimize large shuffle with disk seek batching techniques.class
LoopOptimizationCompositePass
A series of passes to perform LoopOptimization.class
SkewCompositePass
Pass to modify the DAG for a job to perform data skew.class
TransientResourceCompositePass
A series of passes to harness transient resources. -
Uses of Pass in org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping
Subclasses of Pass in org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping Modifier and Type Class Description class
CommonSubexpressionEliminationPass
Pass for Common Subexpression Elimination optimization.class
LargeShuffleReshapingPass
Inserts the RelayVertex for each shuffle edge.class
LoopExtractionPass
Pass for extracting and grouping each loops together using the LoopVertex.static class
LoopOptimizations.LoopFusionPass
Pass for Loop Fusion optimization.static class
LoopOptimizations.LoopInvariantCodeMotionPass
Pass for Loop Invariant Code Motion optimization.class
LoopUnrollingPass
Pass for unrolling the loops grouped by theLoopExtractionPass
.class
ReshapingPass
A compile-time pass that reshapes the structure of the IR DAG.class
SamplingSkewReshapingPass
Optimizes the PartitionSet property of shuffle edges to handle data skews using the SamplingVertex.class
SamplingTaskSizingPass
Compiler pass for dynamic task size optimization.class
SkewReshapingPass
Pass to reshape the IR DAG for skew handling. -
Uses of Pass in org.apache.nemo.compiler.optimizer.pass.runtime
Subclasses of Pass in org.apache.nemo.compiler.optimizer.pass.runtime Modifier and Type Class Description class
DynamicTaskSizingRuntimePass
Runtime pass for Dynamic Task Sizing policy.class
RunTimePass<T>
Abstract class for dynamic optimization passes, for dynamically optimizing the IRDAG.class
SkewRunTimePass
Dynamic optimization pass for handling data skew. -
Uses of Pass in org.apache.nemo.compiler.optimizer.policy
Subclasses of Pass in org.apache.nemo.compiler.optimizer.policy Modifier and Type Class Description static class
DefaultPolicyWithSeparatePass.RefactoredPass
A simple custom pass consisted of the two passes at the end of the default pass.
-