Package org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Interface Summary

Interface	Description
AccumulativeTupleBuffer	This interface is used during Reduce phrase to process tuples in batch mode.

Class Summary

Class	Description
CombinerPackager	The package operator that packages the globally rearranged tuples into output format after the combiner stage.
JoinPackager
LitePackager	This package operator is a specialization of POPackage operator used for the specific case of the order by query.
MultiQueryPackager	The package operator that packages the globally rearranged tuples into output format as required by multi-query de-multiplexer.
Packager
POBroadcastSpark
POCollectedGroup	The collected group operator is a special operator used when users give the hint 'using "collected"' in a group by clause.
POCounter	This operator is part of the RANK operator implementation.
POCross	Recover this class for nested cross operation.
PODemux	The MapReduce Demultiplexer operator.
PODistinct	Find the distinct set of tuples in a bag.
POFilter	This is an implementation of the Filter operator.
POForEach
POFRJoin	The operator models the join keys using the Local Rearrange operators which are configured with the plan specified by the user.
POFRJoin.TupleToMapKey
POFRJoinSpark
POGlobalRearrange	Dummy operator to test MRCompiler.
POLimit
POLoad	The load operator which is used in two ways: 1) As a local operator it can be used to load files 2) In the Map Reduce setting, it is used to create jobs from MapReduce operators which keep the loads and stores in the Map and Reduce Plans till the job is created
POLocalRearrange	The local rearrange operator is a part of the co-group implementation.
POMergeCogroup
POMergeJoin	This operator implements merge join algorithm to do map side joins.
POMergeJoin.TuplesToSchemaTupleList	This is a class that extends ArrayList, making it easy to provide on the fly conversion from Tuple to SchemaTuple.
PONative
POOptimizedForEach	A specialized version of POForeach with the difference that in getNext(), it knows that "input" has already been attached by its input operator which SHOULD be POJoinPackage
POPackage	The package operator that packages the globally rearranged tuples into output format as required by co-group.
POPartialAgg	Do partial aggregation in map plan.
POPartitionRearrange	The partition rearrange operator is a part of the skewed join implementation.
POPoissonSample
POPreCombinerLocalRearrange	A specialized local rearrange operator which behaves like the regular local rearrange in the getNext() as far as getting its input and constructing the "key" out of the input.
PORank	This operator is part of the RANK operator implementation.
POReservoirSample
POSkewedJoin	The PhysicalOperator that represents a skewed join.
POSort	This implementation is applicable for both the physical plan and for the local backend, as the conversion of physical to mapreduce would see the SORT operator and take necessary steps to convert it to a quantile and a sort job.
POSortedDistinct	This operator is a variation of PODistinct, the input to this operator must be sorted already.
POSplit	The MapReduce Split operator.
POStore	The store operator which is used in two ways: 1) As a local operator it can be used to store files 2) In the Map Reduce setting, it is used to create jobs from MapReduce operators which keep the loads and stores in the Map and Reduce Plans till the job is created
POStoreImpl	This class is used to specify the actual behavior of the store operator just when ready to start execution.
POStream
POUnion	The union operator that combines the two inputs into a single stream.
StoreFuncDecorator	This class is used to decorate the StoreFunc#putNext(Tuple).

Enum Summary

Enum	Description
Packager.PackageType