Changed Classes |
CombinerOptimizer
|
Optimize map reduce plans to use the combiner where possible. |
Launcher
|
|
MRCompiler
|
The compiler that compiles a given physical plan into a DAG of MapReduce operators which can then be converted into the JobControl structure. |
MapReduceLauncher
|
Main class that launches pig for Map Reduce |
PhyPlanSetter
|
Sets the parent plan for all Physical Operators. |
PigGenericMapBase
|
This class is the base class for PigMapBase which has slightly difference among different versions of hadoop. |
PigGenericMapReduce.Map
|
|
PigGenericMapReduce.MapWithComparator
|
This "specialized" map class is ONLY to be used in pig queries with order by a udf. |
PigGenericMapReduce.MapWithPartitionIndex
|
Used by Skewed Join |
PigGenericMapReduce.Reduce
|
|
PigGenericMapReduce.ReduceWithComparator
|
This "specialized" reduce class is ONLY to be used in pig queries with order by a udf. |
PigOutputCommitter
|
A specialization of the default FileOutputCommitter to allow pig to inturn delegate calls to the OutputCommiter(s) of the StoreFunc(s)' OutputFormat(s). |
PigRecordReader
|
A wrapper around the actual RecordReader and loadfunc - this is needed for two reasons 1) To intercept the initialize call from hadoop and initialize the underlying actual RecordReader with the right Context object - this is achieved by looking up the Context corresponding to the input split this Reader is supposed to process 2) We need to give hadoop consistent key-value types - text and tuple respectively - so PigRecordReader will call underlying Loader's getNext() to get the Tuple value - the key is null text since key is not used in input to map() in Pig. |
PigSplit
|
The main split class that maintains important information about the input split. |
ProgressableReporter
|
|