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 |
---|---|
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 |
---|---|
void |
IllustratorAttacher.visitPOForEach(POForEach nfe) |
Modifier and Type | Method and Description |
---|---|
void |
ScriptState.AliasVisitor.visitPOForEach(POForEach nfe) |
Copyright © 2007-2012 The Apache Software Foundation