Uses of Class
org.apache.pig.impl.plan.PlanException

Packages that use PlanException

Package	Description
org.apache.pig.backend.executionengine
org.apache.pig.backend.hadoop.executionengine
org.apache.pig.backend.hadoop.executionengine.fetch
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
org.apache.pig.backend.hadoop.executionengine.tez
org.apache.pig.backend.hadoop.executionengine.tez.plan
org.apache.pig.backend.hadoop.executionengine.tez.plan.operator
org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer
org.apache.pig.backend.hadoop.executionengine.tez.util
org.apache.pig.impl.plan
org.apache.pig.impl.util

Uses of PlanException in org.apache.pig.backend.executionengine

Methods in org.apache.pig.backend.executionengine that throw PlanException

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Constructor and Description
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.backend.hadoop.executionengine.tez

Methods in org.apache.pig.backend.hadoop.executionengine.tez that throw PlanException

Modifier and Type	Method and Description
TezPlanContainer	TezLauncher.compile(PhysicalPlan php, PigContext pc)
void	TezLauncher.explain(PhysicalPlan php, PigContext pc, PrintStream ps, String format, boolean verbose)

Uses of PlanException in org.apache.pig.backend.hadoop.executionengine.tez.plan

Methods in org.apache.pig.backend.hadoop.executionengine.tez.plan that throw PlanException

Modifier and Type	Method and Description
void	TezPlanContainer.addPlan(TezOperPlan plan)
TezOperPlan	TezCompiler.compile() The front-end method that the user calls to compile the plan.
TezPlanContainer	TezCompiler.getPlanContainer()
static Pair<POProject,Byte>[]	TezCompiler.getSortCols(List<PhysicalPlan> plans)
void	TezOperPlan.moveTree(TezOperator root, TezOperPlan newPlan) Move everything below a given operator to the new operator plan.
void	TezPlanContainer.split(TezPlanContainerNode planNode)

Uses of PlanException in org.apache.pig.backend.hadoop.executionengine.tez.plan.operator

Methods in org.apache.pig.backend.hadoop.executionengine.tez.plan.operator that throw PlanException

Modifier and Type	Method and Description
POLocalRearrangeTez	POLocalRearrangeTezFactory.create()
POLocalRearrangeTez	POLocalRearrangeTezFactory.create(int index, POLocalRearrangeTezFactory.LocalRearrangeType type)
POLocalRearrangeTez	POLocalRearrangeTezFactory.create(int index, POLocalRearrangeTezFactory.LocalRearrangeType type, List<PhysicalPlan> plans, byte keyType)
POLocalRearrangeTez	POLocalRearrangeTezFactory.create(POLocalRearrangeTezFactory.LocalRearrangeType type)

Uses of PlanException in org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer

Methods in org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer that throw PlanException

Modifier and Type	Method and Description
void	UnionOptimizer.connectPredecessorsToVertexGroups(TezOperator unionOp, TezOperator pred, PhysicalPlan predClonedUnionPlan, TezOperator[] storeVertexGroupOps, TezOperator[] outputVertexGroupOps) Connects the unionOp predecessor to the store vertex groups and the output vertex groups and disconnects it from the unionOp.

Uses of PlanException in org.apache.pig.backend.hadoop.executionengine.tez.util

Methods in org.apache.pig.backend.hadoop.executionengine.tez.util that throw PlanException

Modifier and Type	Method and Description
static TezEdgeDescriptor	TezCompilerUtil.connect(TezOperPlan plan, TezOperator from, TezOperator to)
static void	TezCompilerUtil.connect(TezOperPlan plan, TezOperator from, TezOperator to, TezEdgeDescriptor edge)
static void	TezCompilerUtil.connectTezOpToNewPredecessor(TezOperPlan plan, TezOperator tezOp, TezOperator newPredecessor, TezEdgeDescriptor edge, String oldInputKey)
static void	TezCompilerUtil.connectTezOpToNewSuccesor(TezOperPlan plan, TezOperator tezOp, TezOperator newSuccessor, TezEdgeDescriptor edge, String oldOutputKey)
static boolean	TezCompilerUtil.isNonPackageInput(String inputKey, TezOperator tezOp)
static void	TezCompilerUtil.replaceInput(TezOperator tezOp, String oldInputKey, String newInputKey)
static void	TezCompilerUtil.replaceOutput(TezOperator tezOp, String oldOutputKey, String newOutputKey)
static void	TezCompilerUtil.simpleConnectTwoVertex(TezOperPlan tezPlan, TezOperator op1, TezOperator op2, String scope, NodeIdGenerator nig)

Uses of PlanException in org.apache.pig.impl.plan

Methods in org.apache.pig.impl.plan that throw PlanException

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
static void	CompilerUtils.addEmptyBagOuterJoin(PhysicalPlan fePlan, Schema inputSchema, boolean skewedRightOuterJoin, String isFirstReduceOfKeyClassName)