Uses of Class
org.apache.nemo.compiler.optimizer.pass.compiletime.CompileTimePass
-
-
Uses of CompileTimePass in org.apache.nemo.compiler.optimizer.pass.compiletime.annotating
Subclasses of CompileTimePass 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 CompileTimePass in org.apache.nemo.compiler.optimizer.pass.compiletime.composite
Subclasses of CompileTimePass 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.Methods in org.apache.nemo.compiler.optimizer.pass.compiletime.composite that return types with arguments of type CompileTimePass Modifier and Type Method Description java.util.List<CompileTimePass>
CompositePass. getPassList()
Getter for list of compile time passes.Constructor parameters in org.apache.nemo.compiler.optimizer.pass.compiletime.composite with type arguments of type CompileTimePass Constructor Description CompositePass(java.util.List<CompileTimePass> passList)
Constructor. -
Uses of CompileTimePass in org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping
Subclasses of CompileTimePass 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 CompileTimePass in org.apache.nemo.compiler.optimizer.policy
Subclasses of CompileTimePass 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.Methods in org.apache.nemo.compiler.optimizer.policy that return types with arguments of type CompileTimePass Modifier and Type Method Description java.util.List<CompileTimePass>
PolicyBuilder. getCompileTimePasses()
Getter for compile time passes.Methods in org.apache.nemo.compiler.optimizer.policy with parameters of type CompileTimePass Modifier and Type Method Description PolicyBuilder
PolicyBuilder. registerCompileTimePass(CompileTimePass compileTimePass)
Register a compile time pass.PolicyBuilder
PolicyBuilder. registerCompileTimePass(CompileTimePass compileTimePass, java.util.function.Predicate<IRDAG> condition)
Register compile time pass with its condition under which to run the pass.PolicyBuilder
PolicyBuilder. registerRunTimePass(RunTimePass<?> runTimePass, CompileTimePass runTimePassRegisterer)
Register a run time pass.PolicyBuilder
PolicyBuilder. registerRunTimePass(RunTimePass<?> runTimePass, CompileTimePass runTimePassRegisterer, java.util.function.Predicate<IRDAG> condition)
Register a run time pass.Constructor parameters in org.apache.nemo.compiler.optimizer.policy with type arguments of type CompileTimePass Constructor Description PolicyImpl(java.util.List<CompileTimePass> compileTimePasses, java.util.Set<RunTimePass<?>> runTimePasses)
Constructor.
-