Package org.apache.hadoop.hive.ql.optimizer.spark

Class Summary

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
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.