|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of PlanException in org.apache.pig.backend.executionengine |
|---|
| Methods in org.apache.pig.backend.executionengine that throw PlanException | |
|---|---|
void |
ExecutionEngine.explain(LogicalPlan lp,
PigContext pc,
PrintStream ps,
String format,
boolean verbose,
File dir,
String suffix)
This method handles the backend processing of the Explain command. |
| Uses of PlanException in org.apache.pig.backend.hadoop.executionengine |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine that throw PlanException | |
|---|---|
void |
HExecutionEngine.explain(LogicalPlan lp,
PigContext pc,
PrintStream ps,
String format,
boolean verbose,
File file,
String suffix)
|
abstract void |
Launcher.explain(PhysicalPlan pp,
PigContext pc,
PrintStream ps,
String format,
boolean verbose)
Explain how a pig job will be executed on the underlying infrastructure. |
| Uses of PlanException in org.apache.pig.backend.hadoop.executionengine.fetch |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine.fetch that throw PlanException | |
|---|---|
void |
FetchLauncher.explain(PhysicalPlan pp,
PigContext pc,
PrintStream ps,
String format)
Creates an empty MR plan |
| Uses of PlanException in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that throw PlanException | |
|---|---|
void |
LimitAdjuster.adjust()
|
void |
MRCompiler.aggregateScalarsFiles()
|
MROperPlan |
MRCompiler.compile()
The front-end method that the user calls to compile the plan. |
MROperPlan |
MapReduceLauncher.compile(PhysicalPlan php,
PigContext pc)
|
void |
MRCompiler.connectSoftLink()
|
void |
MapReduceLauncher.explain(PhysicalPlan php,
PigContext pc,
PrintStream ps,
String format,
boolean verbose)
|
PigStats |
MapReduceLauncher.launchPig(PhysicalPlan php,
String grpName,
PigContext pc)
|
void |
MapReduceOper.setMapDoneMultiple(boolean mapDone)
|
void |
MapReduceOper.setMapDoneSingle(boolean mapDone)
|
static void |
MRUtil.simpleConnectMapToReduce(MapReduceOper mro,
String scope,
NodeIdGenerator nig)
|
| Uses of PlanException in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans that throw PlanException | |
|---|---|
void |
PhysicalPlan.connect(PhysicalOperator from,
PhysicalOperator to)
|
void |
PhysicalPlan.replace(PhysicalOperator oldNode,
PhysicalOperator newNode)
|
| Uses of PlanException in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that throw PlanException | |
|---|---|
void |
POLocalRearrange.setPlans(List<PhysicalPlan> plans)
|
void |
POCollectedGroup.setPlans(List<PhysicalPlan> plans)
|
void |
POLocalRearrange.setPlansFromCombiner(List<PhysicalPlan> plans)
|
void |
POLocalRearrange.setSecondaryPlans(List<PhysicalPlan> plans)
|
| Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that throw PlanException | |
|---|---|
POMergeJoin(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
MultiMap<PhysicalOperator,PhysicalPlan> inpPlans,
List<List<Byte>> keyTypes,
LOJoin.JOINTYPE joinType,
Schema leftInputSchema,
Schema rightInputSchema,
Schema mergedInputSchema)
|
|
| Uses of PlanException in org.apache.pig.impl.plan |
|---|
| Methods in org.apache.pig.impl.plan that throw PlanException | |
|---|---|
void |
OperatorPlan.addAsLeaf(E leaf)
Utility method heavily used in the MRCompiler Adds the leaf operator to the plan and connects all existing leaves to the new leaf |
void |
OperatorPlan.connect(E from,
E to)
Create an edge between two nodes. |
void |
OperatorPlan.createSoftLink(E from,
E to)
Create an soft edge between two nodes. |
void |
OperatorPlan.doInsertBetween(E after,
E newNode,
E before,
boolean rewire)
|
void |
OperatorPlan.insertBetween(E after,
E newNode,
E before)
Given two connected nodes add another node between them. |
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. |
void |
OperatorPlan.pushAfter(E first,
E second,
int outputNum)
Push one operator after another. |
void |
OperatorPlan.pushBefore(E first,
E second,
int inputNum)
Push one operator in front of another. |
void |
OperatorPlan.removeAndReconnect(E node)
Remove a node in a way that connects the node's predecessor (if any) with the node's successor (if any). |
void |
OperatorPlan.removeAndReconnectMultiSucc(E node)
Remove a node in a way that connects the node's predecessor (if any) with the node's successors (if any). |
void |
OperatorPlan.replace(E oldNode,
E newNode)
Replace an existing node in the graph with a new node. |
void |
Operator.rewire(Operator<V> oldPred,
int oldPredIndex,
Operator<V> newPred,
boolean useOldPred)
Make any necessary changes to a node based on a change of position in the plan. |
void |
OperatorPlan.swap(E first,
E second)
Swap two operators in a plan. |
| Uses of PlanException in org.apache.pig.impl.util |
|---|
| Methods in org.apache.pig.impl.util that throw PlanException | |
|---|---|
static void |
CompilerUtils.addEmptyBagOuterJoin(PhysicalPlan fePlan,
Schema inputSchema)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||