| Class | Description |
|---|---|
| CombineEquivalentWorkResolver |
CombineEquivalentWorkResolver would search inside SparkWork, find and combine equivalent
works.
|
| SetSparkReducerParallelism |
SetSparkReducerParallelism determines how many reducers should
be run for a given reduce sink, clone from SetReducerParallelism.
|
| SparkJoinHintOptimizer |
This processes joins in which user specified a hint to identify the small-table.
|
| SparkJoinOptimizer |
Converts a join to a more optimized join for the Spark path.
|
| SparkMapJoinOptimizer |
SparkMapJoinOptimizer cloned from ConvertJoinMapJoin is an optimization that replaces a common join
(aka shuffle join) with a map join (aka broadcast or fragment replicate
join when possible.
|
| SparkPartitionPruningSinkDesc | |
| SparkPartitionPruningSinkDesc.DPPTargetInfo | |
| SparkReduceSinkMapJoinProc | |
| SparkReduceSinkMapJoinProc.SparkMapJoinFollowedByGroupByProcessor | |
| SparkSkewJoinProcFactory |
Spark-version of SkewJoinProcFactory.
|
| SparkSkewJoinProcFactory.SparkSkewJoinJoinProcessor | |
| SparkSkewJoinResolver |
Spark version of SkewJoinResolver.
|
| SparkSkewJoinResolver.SparkSkewJoinProcCtx | |
| SparkSMBJoinHintOptimizer |
Converts from a bucket-mapjoin created from hints to SMB mapjoin.
|
| SparkSortMergeJoinFactory |
Operator factory for Spark SMBJoin processing.
|
| SparkSortMergeJoinOptimizer |
Converts a common join operator to an SMB join if eligible.
|
| SplitSparkWorkResolver |
Do a BFS on the sparkWork graph, and look for any work that has more than one child.
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.