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

Packages that use PlanException

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.impl.plan
org.apache.pig.impl.util

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)
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.
PigStats	MapReduceLauncher.launchPig(PhysicalPlan php, String grpName, PigContext pc)
abstract PigStats	Launcher.launchPig(PhysicalPlan php, String grpName, PigContext pc) Method to launch pig for hadoop either for a cluster's job tracker or for a local job runner.
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)

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)