| Class and Description |
|---|
| 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
|
| Class and Description |
|---|
| 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
|
| Class and Description |
|---|
| 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
|
| Class and Description |
|---|
| 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.
|
| Class and Description |
|---|
| 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.
|
| 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.
|
| 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). |
| Class and Description |
|---|
| POCollectedGroup
The collected group operator is a special operator used when users give
the hint 'using "collected"' in a group by clause.
|
| POForEach |
| 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.
|
| POPoissonSample |
| POReservoirSample |
| 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.
|
| POStream |
| Class and Description |
|---|
| 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.
|
| 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.
|
| 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.
|
| 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.
|
| Class and Description |
|---|
| 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 |
| POBroadcastSpark |
| POCounter
This operator is part of the RANK operator implementation.
|
| PODistinct
Find the distinct set of tuples in a bag.
|
| 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 |
| POLocalRearrange
The local rearrange operator is a part of the co-group
implementation.
|
| POMergeJoin.TuplesToSchemaTupleList
This is a class that extends ArrayList, making it easy to provide on the fly conversion
from Tuple to SchemaTuple.
|
| 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.
|
| 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.
|
| 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.
|
| StoreFuncDecorator
This class is used to decorate the
StoreFunc#putNext(Tuple). |
| Class and Description |
|---|
| 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.
|
| 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
|
| POMergeCogroup |
| POMergeJoin
This operator implements merge join algorithm to do map side joins.
|
| 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.
|
| 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.
|
| Class and Description |
|---|
| POForEach |
| POGlobalRearrange
Dummy operator to test MRCompiler.
|
| POLocalRearrange
The local rearrange operator is a part of the co-group
implementation.
|
| POPackage
The package operator that packages
the globally rearranged tuples into
output format as required by co-group.
|
| POPoissonSample |
| 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.
|
| Class and Description |
|---|
| 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.
|
| 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 |
| 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.
|
| 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.
|
| Class and Description |
|---|
| 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.
|
| 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 |
| 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.
|
| 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.
|
| Class and Description |
|---|
| Packager |
| POCounter
This operator is part of the RANK operator implementation.
|
| POFRJoin
The operator models the join keys using the Local Rearrange operators which
are configured with the plan specified by the user.
|
| 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.
|
| 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.
|
| 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
|
| Class and Description |
|---|
| 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 |
| POMergeJoin
This operator implements merge join algorithm to do map side joins.
|
| POPackage
The package operator that packages
the globally rearranged tuples into
output format as required by co-group.
|
| POSplit
The MapReduce Split operator.
|
| Class and Description |
|---|
| 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
|
| Class and Description |
|---|
| POForEach |
| 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
|
| Class and Description |
|---|
| POForEach |
| POLocalRearrange
The local rearrange operator is a part of the co-group
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.
|
| 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
|
| Class and Description |
|---|
| POStream |
| Class and Description |
|---|
| 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
|
| Class and Description |
|---|
| AccumulativeTupleBuffer
This interface is used during Reduce phrase to process tuples
in batch mode.
|
| Packager |
| Class and Description |
|---|
| POStream |
| Class and Description |
|---|
| 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
|
| 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
|
| Class and Description |
|---|
| 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.
|
| Class and Description |
|---|
| 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.
|
| Class and Description |
|---|
| 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
|
| 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
|
Copyright © 2007-2017 The Apache Software Foundation