Modifier and Type | Method and Description |
---|---|
void |
PhyPlanSetter.visitLocalRearrange(POLocalRearrange lr) |
void |
MRCompiler.visitLocalRearrange(POLocalRearrange op) |
Modifier and Type | Method and Description |
---|---|
void |
EndOfAllInputSetter.EndOfAllInputChecker.visitLocalRearrange(POLocalRearrange lr) |
Modifier and Type | Method and Description |
---|---|
void |
PlanPrinter.visitLocalRearrange(POLocalRearrange op) |
void |
PhyPlanVisitor.visitLocalRearrange(POLocalRearrange lr) |
Modifier and Type | Class and Description |
---|---|
class |
POPartitionRearrange
The partition rearrange operator is a part of the skewed join
implementation.
|
Modifier and Type | Field and Description |
---|---|
protected POLocalRearrange[] |
POFRJoin.LRs |
Modifier and Type | Method and Description |
---|---|
POLocalRearrange |
POLocalRearrange.clone()
Make a deep copy of this operator.
|
POLocalRearrange[] |
POMergeJoin.getLRs() |
POLocalRearrange[] |
POFRJoin.getLRs() |
Modifier and Type | Method and Description |
---|---|
protected Tuple |
POFRJoin.getValueTuple(POLocalRearrange lr,
Tuple tuple) |
Constructor and Description |
---|
POLocalRearrange(POLocalRearrange copy) |
POMergeCogroup(OperatorKey k,
List<PhysicalOperator> inpPOs,
POLocalRearrange[] lrs,
int parallel) |
Modifier and Type | Field and Description |
---|---|
protected POLocalRearrange |
POReduceBySpark.lr |
Modifier and Type | Method and Description |
---|---|
POLocalRearrange |
POReduceBySpark.getLROp() |
Modifier and Type | Method and Description |
---|---|
List<POLocalRearrange> |
POJoinGroupSpark.getLROps() |
Constructor and Description |
---|
POReduceBySpark(OperatorKey k,
int rp,
List<PhysicalPlan> inp,
List<Boolean> isToBeFlattened,
POPackage pkg,
POLocalRearrange lr) |
Constructor and Description |
---|
POJoinGroupSpark(List<POLocalRearrange> lraOps,
POGlobalRearrangeSpark glaOp,
POPackage pkgOp) |
Modifier and Type | Method and Description |
---|---|
void |
SparkCompiler.visitLocalRearrange(POLocalRearrange op) |
Modifier and Type | Method and Description |
---|---|
void |
TezPOPackageAnnotator.LoRearrangeDiscoverer.visitLocalRearrange(POLocalRearrange lrearrange) |
void |
TezCompiler.visitLocalRearrange(POLocalRearrange op) |
Modifier and Type | Class and Description |
---|---|
class |
POBloomFilterRearrangeTez |
class |
POBuildBloomRearrangeTez
This operator writes out the key value for the hash join reduce operation similar to POLocalRearrangeTez.
|
class |
POIdentityInOutTez
POIdentityInOutTez is used to pass through tuples as is to next vertex from
previous vertex's POLocalRearrangeTez.
|
class |
POLocalRearrangeTez
POLocalRearrangeTez is used to write to a Tez OrderedPartitionedKVOutput
(shuffle) or UnorderedKVOutput (broadcast)
|
class |
POPartitionRearrangeTez
The partition rearrange operator is a part of the skewed join implementation.
|
Constructor and Description |
---|
POIdentityInOutTez(OperatorKey k,
POLocalRearrange inputRearrange,
String inputKey) |
POLocalRearrangeTez(POLocalRearrange copy) |
Modifier and Type | Method and Description |
---|---|
static POLocalRearrange |
CombinerOptimizerUtil.getNewRearrange(POLocalRearrange rearrange)
create new Local rearrange by cloning existing rearrange and
add plan for projecting the key
|
Modifier and Type | Method and Description |
---|---|
static POLocalRearrange |
CombinerOptimizerUtil.getNewRearrange(POLocalRearrange rearrange)
create new Local rearrange by cloning existing rearrange and
add plan for projecting the key
|
static POPreCombinerLocalRearrange |
CombinerOptimizerUtil.getPreCombinerLR(POLocalRearrange rearrange) |
Modifier and Type | Method and Description |
---|---|
void |
IllustratorAttacher.visitLocalRearrange(POLocalRearrange lr) |
Modifier and Type | Method and Description |
---|---|
void |
ScriptState.AliasVisitor.visitLocalRearrange(POLocalRearrange lr) |
Copyright © 2007-2017 The Apache Software Foundation