| Modifier and Type | Class and Description |
|---|---|
static class |
DotMRPrinter.InnerPlan
Helper class to represent the relationship of map, reduce and
combine phases in an MR operator.
|
class |
MROperPlan
A Plan used to create the plan of
Map Reduce Operators which can be
converted into the Job Control
object.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlanPrinter<O extends Operator,P extends OperatorPlan<O>> |
class |
XMLPhysicalPlanPrinter<P extends OperatorPlan<PhysicalOperator>> |
| Modifier and Type | Class and Description |
|---|---|
class |
PhysicalPlan
The base class for all types of physical plans.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
PatternPlan.match(OperatorPlan<? extends Operator<?>> inpPlan)
Return true if the given plan has nodes that match the pattern
represented by this class
If a match is found, the PatterNodes in the plan will return non
null node for getMatch().
|
| Modifier and Type | Class and Description |
|---|---|
static class |
DotSparkPrinter.InnerPlan
Each spark operator will have and an inner plan of inner
operators.
|
class |
SparkOperPlan
A Plan used to create the physicalPlan of Spark Operators
|
| Modifier and Type | Class and Description |
|---|---|
class |
TezOperPlan
A Plan used to create the plan of Tez operators which can be converted into
the Job Control object.
|
class |
TezPlanContainer |
| Modifier and Type | Class and Description |
|---|---|
class |
DependencyOrderWalker<O extends Operator,P extends OperatorPlan<O>>
DependencyOrderWalker traverses the graph in such a way that no node is visited
before all the nodes it depends on have been visited.
|
class |
DepthFirstWalker<O extends Operator,P extends OperatorPlan<O>>
DepthFirstWalker traverses a plan in a depth first manner.
|
class |
DotPlanDumper<E extends Operator,P extends OperatorPlan<E>,N extends Operator,S extends OperatorPlan<N>>
This class puts everything that is needed to dump a plan in a
format readable by graphviz's dot algorithm.
|
class |
DotPlanDumper<E extends Operator,P extends OperatorPlan<E>,N extends Operator,S extends OperatorPlan<N>>
This class puts everything that is needed to dump a plan in a
format readable by graphviz's dot algorithm.
|
class |
PlanDumper<E extends Operator,P extends OperatorPlan<E>,S extends OperatorPlan<? extends Operator>>
This class dumps a nested plan to a print stream.
|
class |
PlanDumper<E extends Operator,P extends OperatorPlan<E>,S extends OperatorPlan<? extends Operator>>
This class dumps a nested plan to a print stream.
|
class |
PlanVisitor<O extends Operator,P extends OperatorPlan<O>>
A visitor mechanism for navigating and operating on a plan of
Operators.
|
class |
PlanWalker<O extends Operator,P extends OperatorPlan<O>>
PlanWalker encapsulates the logic to traverse a plan.
|
class |
ReverseDependencyOrderWalker<O extends Operator,P extends OperatorPlan<O>>
ReverseDependencyOrderWalker traverses the graph in such a way that no node is visited
before all the nodes that are its successors on have been visited.
|
| Modifier and Type | Field and Description |
|---|---|
protected P |
PlanWalker.mPlan |
protected P |
PlanVisitor.mPlan |
protected P |
PlanDumper.plan |
| Modifier and Type | Method and Description |
|---|---|
OperatorPlan<E> |
OperatorPlan.merge(OperatorPlan<E> inpPlan)
Merges the operators in the incoming operPlan with
this plan's operators.
|
OperatorPlan<E> |
OperatorPlan.mergeSharedPlan(OperatorPlan<E> inpPlan)
Merges the operators in the incoming plan with this plan's operators.
|
| Modifier and Type | Method and Description |
|---|---|
OperatorPlan<E> |
OperatorPlan.merge(OperatorPlan<E> inpPlan)
Merges the operators in the incoming operPlan with
this plan's operators.
|
OperatorPlan<E> |
OperatorPlan.mergeSharedPlan(OperatorPlan<E> inpPlan)
Merges the operators in the incoming plan with this plan's operators.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ScriptState.emitInitialPlanNotification(OperatorPlan<?> plan) |
void |
PigProgressNotificationListener.initialPlanNotification(String scriptId,
OperatorPlan<?> plan)
Invoked before any Hadoop jobs (or a Tez DAG) are run with the plan that is to be executed.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TezScriptState.dagLaunchNotification(String dagName,
OperatorPlan<?> dagPlan,
int numVerticesToLaunch) |
abstract void |
PigTezProgressNotificationListener.dagLaunchNotification(String scriptId,
String dagId,
OperatorPlan<?> dagPlan,
int numVerticesToLaunch)
Invoked just before launching a Tez DAG spawned by the script.
|
Copyright © 2007-2017 The Apache Software Foundation