Uses of Class
org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan

Packages that use PhysicalPlan

Package	Description
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.mapReduceLayer.plans
org.apache.pig.backend.hadoop.executionengine.physicalLayer	Implementation of physical operators that use hadoop as the execution engine and data storage.
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
org.apache.pig.backend.hadoop.executionengine.physicalLayer.util
org.apache.pig.backend.hadoop.executionengine.spark
org.apache.pig.backend.hadoop.executionengine.spark.converter
org.apache.pig.backend.hadoop.executionengine.spark.operator
org.apache.pig.backend.hadoop.executionengine.spark.optimizer
org.apache.pig.backend.hadoop.executionengine.spark.plan
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.backend.hadoop.executionengine.util
org.apache.pig.impl.util
org.apache.pig.newplan.logical.expression
org.apache.pig.newplan.logical.relational
org.apache.pig.pen
org.apache.pig.tools.pigstats

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine

Methods in org.apache.pig.backend.hadoop.executionengine that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	HExecutionEngine.compile(LogicalPlan plan, Properties properties)

Methods in org.apache.pig.backend.hadoop.executionengine with parameters of type PhysicalPlan

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

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.fetch

Methods in org.apache.pig.backend.hadoop.executionengine.fetch with parameters of type PhysicalPlan

Modifier and Type	Method and Description
void	FetchLauncher.explain(PhysicalPlan pp, PigContext pc, PrintStream ps, String format) Creates an empty MR plan
static boolean	FetchOptimizer.isPlanFetchable(PigContext pc, PhysicalPlan pp) Visits the plan with FetchablePlanVisitor and checks whether the plan is fetchable.
PigStats	FetchLauncher.launchPig(PhysicalPlan pp) Runs the fetch task by executing chain of calls on the PhysicalPlan from the leaf up to the LoadFunc

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Fields in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer declared as PhysicalPlan

Modifier and Type	Field and Description
PhysicalPlan	MapReduceOper.combinePlan
PhysicalPlan	MapReduceOper.mapPlan
protected PhysicalPlan	PigGenericMapBase.mp
PhysicalPlan	MapReduceOper.reducePlan
protected PhysicalPlan	PigGenericMapReduce.Reduce.rp

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	MRCompiler.getPlan() Used to get the plan that was compiled

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type PhysicalPlan

Modifier and Type	Method and Description
MROperPlan	MapReduceLauncher.compile(PhysicalPlan php, PigContext pc)
void	MapReduceLauncher.explain(PhysicalPlan php, PigContext pc, PrintStream ps, String format, boolean verbose)
PigStats	MapReduceLauncher.launchPig(PhysicalPlan php, String grpName, PigContext pc)
static void	NoopFilterRemoverUtil.removeFilter(POFilter filter, PhysicalPlan plan)
void	PigGenericMapBase.setMapPlan(PhysicalPlan plan) for local map/reduce simulation
void	PigGenericMapReduce.Reduce.setReducePlan(PhysicalPlan plan) Set the reduce plan: to be used by local runner for illustrator

Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type PhysicalPlan

Constructor and Description
MRCompiler(PhysicalPlan plan)
MRCompiler(PhysicalPlan plan, PigContext pigContext)
PhyPlanSetter(PhysicalPlan plan)
UDFEndOfAllInputNeededVisitor(PhysicalPlan plan)
UDFFinishVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with type arguments of type PhysicalPlan

Constructor and Description
UDFFinishVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	DotMRPrinter.InnerOperator.getPlan()

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with parameters of type PhysicalPlan

Modifier and Type	Method and Description
void	UDFFinder.setPlan(PhysicalPlan plan)

Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with parameters of type PhysicalPlan

Constructor and Description
EndOfAllInputChecker(PhysicalPlan plan)
InnerOperator(PhysicalPlan plan, String name)
InnerPlan(PhysicalPlan mapPlan, PhysicalPlan combinePlan, PhysicalPlan reducePlan)
ScalarPhyFinder(PhysicalPlan plan)
UDFFinder(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with type arguments of type PhysicalPlan

Constructor and Description
UDFFinder(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer declared as PhysicalPlan

Modifier and Type	Field and Description
protected PhysicalPlan	PhysicalOperator.parentPlan

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	PhysicalOperator.getParentPlan()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer that return types with arguments of type PhysicalPlan

Modifier and Type	Method and Description
protected static List<PhysicalPlan>	PhysicalOperator.clonePlans(List<PhysicalPlan> origPlans)

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer with parameters of type PhysicalPlan

Modifier and Type	Method and Description
void	PhysicalOperator.setParentPlan(PhysicalPlan physicalPlan)

Method parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer with type arguments of type PhysicalPlan

Modifier and Type	Method and Description
protected static List<PhysicalPlan>	PhysicalOperator.clonePlans(List<PhysicalPlan> origPlans)

Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer with parameters of type PhysicalPlan

Constructor and Description
POPrinter(PrintStream ps, PhysicalPlan pp)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators with parameters of type PhysicalPlan

Modifier and Type	Method and Description
void	UnaryExpressionOperator.setInputAsExpr(PhysicalPlan plan) Set the contained expression to the be the input value.

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	PhysicalPlan.clone()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans that return types with arguments of type PhysicalPlan

Modifier and Type	Method and Description
protected Collection<PhysicalPlan>	DotPOPrinter.getMultiOutputNestedPlans(PhysicalOperator op)
protected Collection<PhysicalPlan>	DotPOPrinter.getNestedPlans(PhysicalOperator op)

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with parameters of type PhysicalPlan

Modifier and Type	Method and Description
protected DotPlanDumper	DotPOPrinter.makeDumper(PhysicalPlan plan, PrintStream ps)

Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with parameters of type PhysicalPlan

Constructor and Description
DotPOPrinter(PhysicalPlan plan, PrintStream ps)
DotPOPrinter(PhysicalPlan plan, PrintStream ps, boolean isSubGraph, Set<Operator> subgraphs, Set<Operator> multiInputSubgraphs, Set<Operator> multiOutputSubgraphs)
PhyPlanVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)
UdfCacheShipFilesVisitor(PhysicalPlan plan)
XMLPhysicalPlanPrinter(PhysicalPlan plan, Document doc, Element parent)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with type arguments of type PhysicalPlan

Constructor and Description
PhyPlanVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type parameters of type PhysicalPlan

Modifier and Type	Field and Description
protected List<PhysicalPlan>	POForEach.inputPlans
protected List<List<PhysicalPlan>>	POFRJoin.phyPlanLists
protected List<PhysicalPlan>	POPreCombinerLocalRearrange.plans
protected List<PhysicalPlan>	POLocalRearrange.plans
protected List<PhysicalPlan>	POCollectedGroup.plans
protected List<PhysicalPlan>	POLocalRearrange.secondaryPlans

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	POPartialAgg.getKeyPlan()
PhysicalPlan	POLimit.getLimitPlan()
PhysicalPlan	POFilter.getPlan()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return types with arguments of type PhysicalPlan

Modifier and Type	Method and Description
List<PhysicalPlan>	POCounter.getCounterPlans()
List<PhysicalPlan>	POMergeJoin.getInnerPlansOf(int index)
List<PhysicalPlan>	POForEach.getInputPlans()
List<PhysicalPlan>	JoinPackager.getInputPlans()
MultiMap<PhysicalOperator,PhysicalPlan>	POSkewedJoin.getJoinPlans()
List<List<PhysicalPlan>>	POFRJoin.getJoinPlans()
List<PhysicalPlan>	POMergeCogroup.getLRInnerPlansOf(int i)
List<PhysicalPlan>	POSplit.getPlans() Returns the list of nested plans.
List<PhysicalPlan>	POPreCombinerLocalRearrange.getPlans()
List<PhysicalPlan>	POLocalRearrange.getPlans()
List<PhysicalPlan>	PODemux.getPlans() Returns the list of inner plans.
List<PhysicalPlan>	POCollectedGroup.getPlans()
List<PhysicalPlan>	PORank.getRankPlans()
List<PhysicalPlan>	POSort.getSortPlans()
List<PhysicalPlan>	POPartialAgg.getValuePlans()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type PhysicalPlan

Modifier and Type	Method and Description
void	POForEach.addInputPlan(PhysicalPlan plan, boolean flatten)
void	POSplit.addPlan(PhysicalPlan inPlan) Appends the specified plan to the end of the nested input plan list
void	PODemux.addPlan(PhysicalPlan inPlan) Appends the specified plan at the end of the list.
void	POSplit.removePlan(PhysicalPlan plan) Removes plan from the nested input plan list
void	POPartialAgg.setKeyPlan(PhysicalPlan keyPlan)
void	POLimit.setLimitPlan(PhysicalPlan expressionPlan)
void	POFilter.setPlan(PhysicalPlan plan)
void	POMergeJoin.setupRightPipeline(PhysicalPlan rightPipeline)

Method parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type arguments of type PhysicalPlan

Modifier and Type	Method and Description
void	POCounter.setCounterPlans(List<PhysicalPlan> counterPlans)
void	POForEach.setInputPlans(List<PhysicalPlan> plans)
void	JoinPackager.setInputPlans(List<PhysicalPlan> plans)
void	POSkewedJoin.setJoinPlans(MultiMap<PhysicalOperator,PhysicalPlan> joinPlans)
void	POPreCombinerLocalRearrange.setPlans(List<PhysicalPlan> plans)
void	POLocalRearrange.setPlans(List<PhysicalPlan> plans)
void	POCollectedGroup.setPlans(List<PhysicalPlan> plans)
void	POLocalRearrange.setPlansFromCombiner(List<PhysicalPlan> plans)
void	PORank.setRankPlans(List<PhysicalPlan> rankPlans)
void	POLocalRearrange.setSecondaryPlans(List<PhysicalPlan> plans)
void	POSort.setSortPlans(List<PhysicalPlan> sortPlans)
void	POPartialAgg.setValuePlans(List<PhysicalPlan> valuePlans)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type arguments of type PhysicalPlan

Constructor and Description
POCounter(OperatorKey operatorKey, int requestedParallelism, List inp, List<PhysicalPlan> counterPlans, List<Boolean> ascendingCol)
POForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
POForEach(OperatorKey operatorKey, int requestedParallelism, List<PhysicalPlan> innerPlans, List<Boolean> flattenList, Schema schema)
POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple)
POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple, Schema[] inputSchemas, Schema[] keySchemas)
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)
POOptimizedForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
PORank(OperatorKey operatorKey, int requestedParallelism, List inp, List<PhysicalPlan> rankPlans, List<Boolean> ascendingCol)
POSort(OperatorKey k, int rp, List inp, List<PhysicalPlan> sortPlans, List<Boolean> mAscCols, POUserComparisonFunc mSortFunc)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util that return PhysicalPlan

Modifier and Type	Method and Description
static PhysicalPlan	PlanHelper.getLocalRearrangePlanFromSplit(PhysicalPlan plan, OperatorKey rearrangeKey) Finds POLocalRearrange from POSplit sub-plan

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util with parameters of type PhysicalPlan

Modifier and Type	Method and Description
static <C extends PhysicalOperator> boolean	PlanHelper.containsPhysicalOperator(PhysicalPlan plan, Class<C> opClass)
static PhysicalPlan	PlanHelper.getLocalRearrangePlanFromSplit(PhysicalPlan plan, OperatorKey rearrangeKey) Finds POLocalRearrange from POSplit sub-plan
static <C> LinkedList<C>	PlanHelper.getPhysicalOperators(PhysicalPlan plan, Class<C> opClass) Returns a LinkedList of operators contained within the physical plan which implement the supplied class, in dependency order.

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.spark

Methods in org.apache.pig.backend.hadoop.executionengine.spark with parameters of type PhysicalPlan

Modifier and Type	Method and Description
SparkOperPlan	SparkLauncher.compile(PhysicalPlan physicalPlan, PigContext pigContext)
void	SparkLauncher.explain(PhysicalPlan pp, PigContext pc, PrintStream ps, String format, boolean verbose)
PigStats	SparkLauncher.launchPig(PhysicalPlan physicalPlan, String grpName, PigContext pigContext)
static org.apache.hadoop.mapred.JobConf	SparkUtil.newJobConf(PigContext pigContext, PhysicalPlan physicalPlan, SparkEngineConf sparkEngineConf)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.spark.converter

Constructors in org.apache.pig.backend.hadoop.executionengine.spark.converter with parameters of type PhysicalPlan

Constructor and Description
LoadConverter(PigContext pigContext, PhysicalPlan physicalPlan, SparkContext sparkContext, org.apache.hadoop.mapred.JobConf jobConf, SparkEngineConf sparkEngineConf)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.spark.operator

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.spark.operator with type arguments of type PhysicalPlan

Constructor and Description
POReduceBySpark(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened, POPackage pkg, POLocalRearrange lr)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.spark.optimizer

Methods in org.apache.pig.backend.hadoop.executionengine.spark.optimizer with parameters of type PhysicalPlan

Modifier and Type	Method and Description
protected PhysicalOperator	SparkSecondaryKeyOptimizerUtil.getCurrentNode(PhysicalOperator root, PhysicalPlan reducePlan)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.spark.plan

Fields in org.apache.pig.backend.hadoop.executionengine.spark.plan declared as PhysicalPlan

Modifier and Type	Field and Description
PhysicalPlan	SparkOperator.physicalPlan

Methods in org.apache.pig.backend.hadoop.executionengine.spark.plan that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	DotSparkPrinter.InnerOperator.getPlan()

Constructors in org.apache.pig.backend.hadoop.executionengine.spark.plan with parameters of type PhysicalPlan

Constructor and Description
InnerOperator(PhysicalPlan plan, String name)
InnerPlan(PhysicalPlan plan)
SparkCompiler(PhysicalPlan physicalPlan, PigContext pigContext)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.tez

Methods in org.apache.pig.backend.hadoop.executionengine.tez with parameters of type PhysicalPlan

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)
PigStats	TezLauncher.launchPig(PhysicalPlan php, String grpName, PigContext pc)

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

Fields in org.apache.pig.backend.hadoop.executionengine.tez.plan declared as PhysicalPlan

Modifier and Type	Field and Description
PhysicalPlan	TezEdgeDescriptor.combinePlan
PhysicalPlan	TezOperator.plan

Method parameters in org.apache.pig.backend.hadoop.executionengine.tez.plan with type arguments of type PhysicalPlan

Modifier and Type	Method and Description
static Pair<POProject,Byte>[]	TezCompiler.getSortCols(List<PhysicalPlan> plans)

Constructors in org.apache.pig.backend.hadoop.executionengine.tez.plan with parameters of type PhysicalPlan

Constructor and Description
LoRearrangeDiscoverer(PhysicalPlan predPlan, TezOperator predTezOpVertexGrp, TezOperator pkgTezOp, POPackage pkg)
TezCompiler(PhysicalPlan plan, PigContext pigContext)

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

Method parameters in org.apache.pig.backend.hadoop.executionengine.tez.plan.operator with type arguments of type PhysicalPlan

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

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

Methods in org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer that return PhysicalPlan

Modifier and Type	Method and Description
static PhysicalPlan	UnionOptimizer.getUnionPredPlanFromSplit(PhysicalPlan plan, String unionOpKey)

Methods in org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer with parameters of type PhysicalPlan

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.
static PhysicalPlan	UnionOptimizer.getUnionPredPlanFromSplit(PhysicalPlan plan, String unionOpKey)

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

Methods in org.apache.pig.backend.hadoop.executionengine.tez.util with parameters of type PhysicalPlan

Modifier and Type	Method and Description
static boolean	TezCompilerUtil.bagDataTypeInCombinePlan(PhysicalPlan combinePlan)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.util

Methods in org.apache.pig.backend.hadoop.executionengine.util that return PhysicalPlan

Modifier and Type	Method and Description
static PhysicalPlan	CombinerOptimizerUtil.createPlanWithPredecessors(PhysicalOperator algeOp, PhysicalPlan pplan) Create new plan and add to it the clones of operator algeOp and its predecessors from the physical plan pplan .

Methods in org.apache.pig.backend.hadoop.executionengine.util that return types with arguments of type PhysicalPlan

Modifier and Type	Method and Description
static List<Pair<PhysicalOperator,PhysicalPlan>>	CombinerOptimizerUtil.findAlgebraicOps(List<PhysicalPlan> feInners) find algebraic operators and also check if the foreach statement is suitable for combiner use

Methods in org.apache.pig.backend.hadoop.executionengine.util with parameters of type PhysicalPlan

Modifier and Type	Method and Description
static void	AccumulatorOptimizerUtil.addAccumulator(PhysicalPlan plan, List<PhysicalOperator> pos)
static void	CombinerOptimizerUtil.addCombiner(PhysicalPlan mapPlan, PhysicalPlan reducePlan, PhysicalPlan combinePlan, CompilationMessageCollector messageCollector, boolean doMapAgg) Algebraic functions and distinct in nested plan of a foreach are partially computed in the map and combine phase.
SecondaryKeyOptimizerUtil.SecondaryKeyOptimizerInfo	SecondaryKeyOptimizerUtil.applySecondaryKeySort(PhysicalPlan mapPlan, PhysicalPlan reducePlan)
static FileSpec	MapRedUtil.checkLeafIsStore(PhysicalPlan plan, PigContext pigContext)
static PhysicalPlan	CombinerOptimizerUtil.createPlanWithPredecessors(PhysicalOperator algeOp, PhysicalPlan pplan) Create new plan and add to it the clones of operator algeOp and its predecessors from the physical plan pplan .
protected PhysicalOperator	SecondaryKeyOptimizerUtil.getCurrentNode(PhysicalOperator root, PhysicalPlan reducePlan)

Method parameters in org.apache.pig.backend.hadoop.executionengine.util with type arguments of type PhysicalPlan

Modifier and Type	Method and Description
static List<Pair<PhysicalOperator,PhysicalPlan>>	CombinerOptimizerUtil.findAlgebraicOps(List<PhysicalPlan> feInners) find algebraic operators and also check if the foreach statement is suitable for combiner use

Constructors in org.apache.pig.backend.hadoop.executionengine.util with parameters of type PhysicalPlan

Constructor and Description
DistinctPatcher(PhysicalPlan physicalPlan)
DistinctPatcher(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)
fixMapProjects(PhysicalPlan plan)
fixMapProjects(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)
ParallelConstantVisitor(PhysicalPlan plan, int rp)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.util with type arguments of type PhysicalPlan

Constructor and Description
DistinctPatcher(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)
fixMapProjects(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Uses of PhysicalPlan in org.apache.pig.impl.util

Methods in org.apache.pig.impl.util with parameters of type PhysicalPlan

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

Uses of PhysicalPlan in org.apache.pig.newplan.logical.expression

Fields in org.apache.pig.newplan.logical.expression declared as PhysicalPlan

Modifier and Type	Field and Description
protected PhysicalPlan	ExpToPhyTranslationVisitor.currentPlan

Fields in org.apache.pig.newplan.logical.expression with type parameters of type PhysicalPlan

Modifier and Type	Field and Description
protected Deque<PhysicalPlan>	ExpToPhyTranslationVisitor.currentPlans

Methods in org.apache.pig.newplan.logical.expression that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	ExpToPhyTranslationVisitor.getPhysicalPlan()

Constructors in org.apache.pig.newplan.logical.expression with parameters of type PhysicalPlan

Constructor and Description
ExpToPhyTranslationVisitor(OperatorPlan plan, LogicalRelationalOperator op, PhysicalPlan phyPlan, Map<Operator,PhysicalOperator> map)
ExpToPhyTranslationVisitor(OperatorPlan plan, PlanWalker walker, LogicalRelationalOperator op, PhysicalPlan phyPlan, Map<Operator,PhysicalOperator> map)

Uses of PhysicalPlan in org.apache.pig.newplan.logical.relational

Fields in org.apache.pig.newplan.logical.relational declared as PhysicalPlan

Modifier and Type	Field and Description
protected PhysicalPlan	LogToPhyTranslationVisitor.currentPlan

Fields in org.apache.pig.newplan.logical.relational with type parameters of type PhysicalPlan

Modifier and Type	Field and Description
protected Deque<PhysicalPlan>	LogToPhyTranslationVisitor.currentPlans

Methods in org.apache.pig.newplan.logical.relational that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	LogToPhyTranslationVisitor.getPhysicalPlan()

Methods in org.apache.pig.newplan.logical.relational with parameters of type PhysicalPlan

Modifier and Type	Method and Description
static void	LogToPhyTranslationVisitor.updateWithEmptyBagCheck(PhysicalPlan fePlan, Operator joinInput) updates plan with check for empty bag and if bag is empty to flatten a bag with as many null's as dictated by the schema

Uses of PhysicalPlan in org.apache.pig.pen

Methods in org.apache.pig.pen with parameters of type PhysicalPlan

Modifier and Type	Method and Description
static Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>>	EquivalenceClasses.getLoToEqClassMap(PhysicalPlan plan, LogicalPlan lp, Map<Operator,PhysicalOperator> logToPhyMap, Map<Operator,DataBag> logToDataMap, Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> forEachInnerLogToPhyMap, HashMap<PhysicalOperator,Collection<IdentityHashSet<Tuple>>> poToEqclassesMap)
void	LocalMapReduceSimulator.launchPig(PhysicalPlan php, Map<LOLoad,DataBag> baseData, LineageTracer lineage, IllustratorAttacher attacher, ExampleGenerator eg, PigContext pc)
void	IllustratorAttacher.revisit(PhysicalPlan plan) revisit an enhanced physical plan from MR compilation

Constructors in org.apache.pig.pen with parameters of type PhysicalPlan

Constructor and Description
IllustratorAttacher(PhysicalPlan plan, LineageTracer lineage, int maxRecords, Map<POLoad,LogicalSchema> poLoadToSchemaMap, PigContext hadoopPigContext)
LineageTrimmingVisitor(LogicalPlan plan, Map<LOLoad,DataBag> baseData, ExampleGenerator eg, Map<Operator,PhysicalOperator> LogToPhyMap, PhysicalPlan physPlan, PigContext pc)
PhysicalPlanResetter(PhysicalPlan plan)

Uses of PhysicalPlan in org.apache.pig.tools.pigstats

Constructors in org.apache.pig.tools.pigstats with parameters of type PhysicalPlan

Constructor and Description
AliasVisitor(PhysicalPlan plan, List<String> alias, List<String> aliasLocation)
FeatureVisitor(PhysicalPlan plan, BitSet feature)