Changed Classes |
POCollectedGroup
|
The collected group operator is a special operator used when users give the hint 'using "collected"' in a group by clause. |
POCombinerPackage
|
The package operator that packages the globally rearranged tuples into output format after the combiner stage. |
PODemux
|
The MapReduce Demultiplexer operator. |
PODistinct
|
Find the distinct set of tuples in a bag. |
POFRJoin
|
The operator models the join keys using the Local Rearrange operators which are configured with the plan specified by the user. |
POFilter
|
This is an implementation of the Filter operator. |
POForEach
|
|
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
|
|
POPackage
|
The package operator that packages the globally rearranged tuples into output format as required by co-group. |
POPackageLite
|
This package operator is a specialization of POPackage operator used for the specific case of the order by query. |
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. |
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. |