Modifier and Type | Class and Description |
---|---|
class |
MRCompiler
The compiler that compiles a given physical plan
into a DAG of MapReduce operators which can then
be converted into the JobControl structure.
|
class |
PhyPlanSetter
Sets the parent plan for all Physical Operators.
|
class |
UDFEndOfAllInputNeededVisitor |
class |
UDFFinishVisitor |
Modifier and Type | Class and Description |
---|---|
static class |
EndOfAllInputSetter.EndOfAllInputChecker |
class |
ScalarPhyFinder |
class |
UDFFinder |
Modifier and Type | Class and Description |
---|---|
class |
POPrinter |
Modifier and Type | Method and Description |
---|---|
abstract void |
PhysicalOperator.visit(PhyPlanVisitor v) |
Modifier and Type | Method and Description |
---|---|
void |
Subtract.visit(PhyPlanVisitor v) |
void |
POUserFunc.visit(PhyPlanVisitor v) |
void |
POUserComparisonFunc.visit(PhyPlanVisitor v) |
void |
PORelationToExprProject.visit(PhyPlanVisitor v) |
void |
PORegexp.visit(PhyPlanVisitor v) |
void |
POProject.visit(PhyPlanVisitor v) |
void |
POOr.visit(PhyPlanVisitor v) |
void |
PONot.visit(PhyPlanVisitor v) |
void |
PONegative.visit(PhyPlanVisitor v) |
void |
POMapLookUp.visit(PhyPlanVisitor v) |
void |
POIsNull.visit(PhyPlanVisitor v) |
void |
POCast.visit(PhyPlanVisitor v) |
void |
POBinCond.visit(PhyPlanVisitor v) |
void |
POAnd.visit(PhyPlanVisitor v) |
void |
NotEqualToExpr.visit(PhyPlanVisitor v) |
void |
Multiply.visit(PhyPlanVisitor v) |
void |
Mod.visit(PhyPlanVisitor v) |
void |
LessThanExpr.visit(PhyPlanVisitor v) |
void |
LTOrEqualToExpr.visit(PhyPlanVisitor v) |
void |
GreaterThanExpr.visit(PhyPlanVisitor v) |
void |
GTOrEqualToExpr.visit(PhyPlanVisitor v) |
abstract void |
ExpressionOperator.visit(PhyPlanVisitor v) |
void |
EqualToExpr.visit(PhyPlanVisitor v) |
void |
Divide.visit(PhyPlanVisitor v) |
void |
ConstantExpression.visit(PhyPlanVisitor v) |
void |
Add.visit(PhyPlanVisitor v) |
Modifier and Type | Class and Description |
---|---|
class |
UdfCacheShipFilesVisitor |
class |
XMLPhysicalPlanPrinter<P extends OperatorPlan<PhysicalOperator>> |
Modifier and Type | Method and Description |
---|---|
void |
POUnion.visit(PhyPlanVisitor v) |
void |
POStream.visit(PhyPlanVisitor v) |
void |
POStore.visit(PhyPlanVisitor v) |
void |
POSplit.visit(PhyPlanVisitor v) |
void |
POSort.visit(PhyPlanVisitor v) |
void |
POSkewedJoin.visit(PhyPlanVisitor v) |
void |
POReservoirSample.visit(PhyPlanVisitor v) |
void |
PORank.visit(PhyPlanVisitor v) |
void |
POPreCombinerLocalRearrange.visit(PhyPlanVisitor v) |
void |
POPoissonSample.visit(PhyPlanVisitor v) |
void |
POPartialAgg.visit(PhyPlanVisitor v) |
void |
POPackage.visit(PhyPlanVisitor v) |
void |
POOptimizedForEach.visit(PhyPlanVisitor v) |
void |
PONative.visit(PhyPlanVisitor v) |
void |
POMergeJoin.visit(PhyPlanVisitor v) |
void |
POMergeCogroup.visit(PhyPlanVisitor v) |
void |
POLocalRearrange.visit(PhyPlanVisitor v) |
void |
POLoad.visit(PhyPlanVisitor v) |
void |
POLimit.visit(PhyPlanVisitor v) |
void |
POGlobalRearrange.visit(PhyPlanVisitor v) |
void |
POForEach.visit(PhyPlanVisitor v) |
void |
POFilter.visit(PhyPlanVisitor v) |
void |
POFRJoin.visit(PhyPlanVisitor v) |
void |
PODistinct.visit(PhyPlanVisitor v) |
void |
PODemux.visit(PhyPlanVisitor v) |
void |
POCross.visit(PhyPlanVisitor v) |
void |
POCounter.visit(PhyPlanVisitor v) |
void |
POCollectedGroup.visit(PhyPlanVisitor v) |
void |
POBroadcastSpark.visit(PhyPlanVisitor v) |
Modifier and Type | Method and Description |
---|---|
void |
POSampleSortSpark.visit(PhyPlanVisitor v) |
void |
POJoinGroupSpark.visit(PhyPlanVisitor v) |
Modifier and Type | Class and Description |
---|---|
class |
SparkCompiler
The compiler that compiles a given physical physicalPlan into a DAG of Spark
operators
|
Modifier and Type | Class and Description |
---|---|
class |
TezCompiler
The compiler that compiles a given physical plan into a DAG of Tez
operators which can then be converted into the JobControl structure.
|
static class |
TezPOPackageAnnotator.LoRearrangeDiscoverer
Physical Plan visitor which tries to get the
LocalRearrange(s) present in the plan (if any) and
annotate the POPackage given to it with the information
in the LocalRearrange (regarding columns in the "value"
present in the "key")
|
Modifier and Type | Method and Description |
---|---|
void |
POValueOutputTez.visit(PhyPlanVisitor v) |
void |
POValueInputTez.visit(PhyPlanVisitor v) |
void |
POShuffledValueInputTez.visit(PhyPlanVisitor v) |
void |
PORankTez.visit(PhyPlanVisitor v) |
void |
POCounterTez.visit(PhyPlanVisitor v) |
void |
POCounterStatsTez.visit(PhyPlanVisitor v) |
Modifier and Type | Class and Description |
---|---|
static class |
TezOperDependencyParallelismEstimator.TezParallelismFactorVisitor |
Modifier and Type | Class and Description |
---|---|
static class |
CombinerOptimizerUtil.DistinctPatcher
A visitor to replace
Project[bag][*]
|
|---PODistinct[bag]
with
POUserFunc(org.apache.pig.builtin.Distinct)[DataBag]
|
static class |
CombinerOptimizerUtil.fixMapProjects |
class |
ParallelConstantVisitor |
Modifier and Type | Class and Description |
---|---|
class |
UDFContextSeparator |
Modifier and Type | Class and Description |
---|---|
class |
IllustratorAttacher
The class used to (re)attach illustrators to physical operators
|
class |
PhysicalPlanResetter
This visitor visits the physical plan and resets it for next MRCompilation
|
Modifier and Type | Class and Description |
---|---|
protected static class |
ScriptState.AliasVisitor |
protected static class |
ScriptState.FeatureVisitor |
Copyright © 2007-2017 The Apache Software Foundation