Modifier and Type | Method and Description |
---|---|
void |
PhyPlanSetter.visitFRJoin(POFRJoin join) |
void |
MRCompiler.visitFRJoin(POFRJoin op)
This is an operator which will have multiple inputs(= to number of join inputs)
But it prunes off all inputs but the fragment input and creates separate MR jobs
for each of the replicated inputs and uses these as the replicated files that
are configured in the POFRJoin operator.
|
Modifier and Type | Method and Description |
---|---|
void |
PhyPlanVisitor.visitFRJoin(POFRJoin join) |
Modifier and Type | Class and Description |
---|---|
class |
POFRJoinSpark |
Modifier and Type | Method and Description |
---|---|
POFRJoin |
POFRJoin.clone() |
Constructor and Description |
---|
POFRJoin(POFRJoin copy) |
POFRJoinSpark(POFRJoin copy) |
Modifier and Type | Method and Description |
---|---|
<any> |
FRJoinConverter.convert(List<<any>> predecessors,
POFRJoin poFRJoin) |
Modifier and Type | Method and Description |
---|---|
void |
SparkCompiler.visitFRJoin(POFRJoin op) |
Modifier and Type | Method and Description |
---|---|
void |
TezCompiler.visitFRJoin(POFRJoin op) |
Modifier and Type | Class and Description |
---|---|
class |
POFRJoinTez
POFRJoinTez is used on the backend to load replicated table from Tez
ShuffleUnorderedKVInput and load fragmented table from data pipeline.
|
Constructor and Description |
---|
POFRJoinTez(POFRJoin copy,
List<String> inputKeys) |
Modifier and Type | Method and Description |
---|---|
void |
TezOperDependencyParallelismEstimator.TezParallelismFactorVisitor.visitFRJoin(POFRJoin join) |
Modifier and Type | Method and Description |
---|---|
void |
ScriptState.FeatureVisitor.visitFRJoin(POFRJoin join) |
void |
ScriptState.AliasVisitor.visitFRJoin(POFRJoin join) |
Copyright © 2007-2017 The Apache Software Foundation