Package org.apache.pig.backend.hadoop.executionengine.spark.optimizer

Class Summary

Class	Description
AccumulatorOptimizer	A visitor to optimize plans that determines if a vertex plan can run in accumulative mode.
CombinerOptimizer	This class goes through the physical plan are replaces GlobalRearrange with ReduceBy where there are algebraic operations.
JoinGroupOptimizerSpark	Collapse LocalRearrange,GlobalRearrange,Package to POJoinGroupSpark to reduce unnecessary map operations to optimize join/group.
MultiQueryOptimizerSpark	MultiQueryOptimizer for spark
NoopFilterRemover	For historical reasons splits will always produce filters that pass everything through unchanged.
ParallelismSetter
SecondaryKeyOptimizerSpark	Secondary key sort optimization for spark mode
SparkSecondaryKeyOptimizerUtil