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

Packages that use org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

org.apache.pig	Public interfaces and classes for Pig.
org.apache.pig.backend.executionengine
org.apache.pig.backend.hadoop.executionengine
org.apache.pig.backend.hadoop.executionengine.fetch
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans
org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
org.apache.pig.backend.hadoop.executionengine.util
org.apache.pig.backend.hadoop.streaming
org.apache.pig.builtin	This package contains builtin Pig UDFs.
org.apache.pig.data	This package contains implementations of Pig specific data types as well as support functions for reading, writing, and using all Pig data types.
org.apache.pig.impl.streaming
org.apache.pig.pen
org.apache.pig.tools.pigstats

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig

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

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.executionengine

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

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.hadoop.executionengine

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

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.hadoop.executionengine.fetch

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.

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

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.

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.

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.

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.

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.

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.

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans

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.

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans

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.

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.

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.

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.

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.

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

POStream

POUnion
The union operator that combines the two inputs into a single stream.

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

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

LitePackager
This package operator is a specialization of POPackage operator used for the specific case of the order by query.

Packager

Packager.PackageType

PODistinct
Find the distinct set of tuples in a bag.

POForEach

POLimit

POLocalRearrange
The local rearrange operator is a part of the co-group implementation.

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.

POPartitionRearrange
The partition rearrange operator is a part of the skewed join implementation.

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.

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.

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.hadoop.executionengine.util

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

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.backend.hadoop.streaming

POStream

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.builtin

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

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.data

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

Packager

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.impl.streaming

POStream

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.pen

POCounter
This operator is part of the RANK operator implementation.

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

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.

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.

PORank
This operator is part of the RANK operator implementation.

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.

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

POStream

POUnion
The union operator that combines the two inputs into a single stream.

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators used by org.apache.pig.tools.pigstats

POCollectedGroup
The collected group operator is a special operator used when users give the hint 'using "collected"' in a group by clause.

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.

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.

POPartialAgg
Do partial aggregation in map plan.

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.

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

POStream

POUnion
The union operator that combines the two inputs into a single stream.