Modifier and Type | Method and Description |
---|---|
static POForEach |
MRUtil.getPlainForEachOP(String scope,
NodeIdGenerator nig) |
Modifier and Type | Method and Description |
---|---|
void |
PhyPlanSetter.visitPOForEach(POForEach nfe) |
void |
MRCompiler.visitPOForEach(POForEach op) |
Modifier and Type | Method and Description |
---|---|
void |
EndOfAllInputSetter.EndOfAllInputChecker.visitPOForEach(POForEach foreach) |
Modifier and Type | Method and Description |
---|---|
void |
PhyPlanVisitor.visitPOForEach(POForEach nfe) |
Modifier and Type | Class and Description |
---|---|
class |
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
|
Modifier and Type | Field and Description |
---|---|
protected POForEach |
POFRJoin.fe |
Modifier and Type | Method and Description |
---|---|
POForEach |
POForEach.clone()
Make a deep copy of this operator.
|
Constructor and Description |
---|
JoinPackager(Packager p,
POForEach f) |
Modifier and Type | Method and Description |
---|---|
<any> |
ForEachConverter.convert(List<<any>> predecessors,
POForEach physicalOperator) |
Modifier and Type | Class and Description |
---|---|
class |
POReduceBySpark
ReduceBy operator that maps to Sparks ReduceBy.
|
Modifier and Type | Method and Description |
---|---|
void |
SparkCompiler.visitPOForEach(POForEach op) |
Modifier and Type | Method and Description |
---|---|
void |
TezCompiler.visitPOForEach(POForEach op) |
Modifier and Type | Method and Description |
---|---|
void |
TezOperDependencyParallelismEstimator.TezParallelismFactorVisitor.visitPOForEach(POForEach nfe) |
Modifier and Type | Method and Description |
---|---|
static POForEach |
TezCompilerUtil.getForEach(POProject project,
int rp,
String scope,
NodeIdGenerator nig) |
static POForEach |
TezCompilerUtil.getForEachPlain(String scope,
NodeIdGenerator nig) |
Modifier and Type | Method and Description |
---|---|
static POForEach |
CombinerOptimizerUtil.createForEachWithGrpProj(POForEach foreach,
byte keyType)
Create a new foreach with same scope,alias as given foreach
add an inner plan that projects the group column, which is going to be
the first input
|
Modifier and Type | Method and Description |
---|---|
static void |
CombinerOptimizerUtil.addAlgebraicFuncToCombineFE(POForEach cfe,
Map<PhysicalOperator,Integer> op2newpos)
add algebraic functions with appropriate projection to new foreach in combiner
|
static void |
CombinerOptimizerUtil.changeFunc(POForEach fe,
byte type)
Change the algebriac function type for algebraic functions in map and combine
In map and combine the algebraic functions will be leaf of the plan
|
static POForEach |
CombinerOptimizerUtil.createForEachWithGrpProj(POForEach foreach,
byte keyType)
Create a new foreach with same scope,alias as given foreach
add an inner plan that projects the group column, which is going to be
the first input
|
Modifier and Type | Method and Description |
---|---|
void |
IllustratorAttacher.visitPOForEach(POForEach nfe) |
Modifier and Type | Method and Description |
---|---|
void |
ScriptState.AliasVisitor.visitPOForEach(POForEach nfe) |
Copyright © 2007-2017 The Apache Software Foundation