Uses of Class
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

Packages that use PhysicalOperator

Package	Description
org.apache.pig.backend.hadoop.executionengine
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.tez.plan
org.apache.pig.backend.hadoop.executionengine.tez.plan.operator
org.apache.pig.backend.hadoop.executionengine.tez.runtime
org.apache.pig.newplan.logical.expression
org.apache.pig.newplan.logical.relational
org.apache.pig.pen

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

Fields in org.apache.pig.backend.hadoop.executionengine with type parameters of type PhysicalOperator

Modifier and Type	Field and Description
protected Map<Operator,PhysicalOperator>	HExecutionEngine.newLogToPhyMap

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

Modifier and Type	Method and Description
Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>>	HExecutionEngine.getForEachInnerLogToPhyMap(LogicalPlan plan)
Map<Operator,PhysicalOperator>	HExecutionEngine.getLogToPhyMap()

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

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

Modifier and Type	Field and Description
static PhysicalOperator	PigMapReduceCounter.PigReduceCounter.leaf

Fields in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with type parameters of type PhysicalOperator

Modifier and Type	Field and Description
static List<PhysicalOperator>	PigMapReduceCounter.PigReduceCounter.leaves
MultiMap<PhysicalOperator,PhysicalOperator>	MapReduceOper.phyToMRMap
MultiMap<PhysicalOperator,PhysicalOperator>	MapReduceOper.phyToMRMap
Set<PhysicalOperator>	MapReduceOper.scalars

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

Modifier and Type	Method and Description
protected void	PigGenericMapReduce.MapWithPartitionIndex.runPipeline(PhysicalOperator leaf)
protected void	PigGenericMapReduce.Reduce.runPipeline(PhysicalOperator leaf)
protected void	PigGenericMapBase.runPipeline(PhysicalOperator leaf)
void	PhyPlanSetter.visit(PhysicalOperator op)

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

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

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

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

Modifier and Type	Method and Description
List<PhysicalOperator>	ScalarPhyFinder.getScalars()

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

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

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

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

Modifier and Type	Field and Description
protected List<PhysicalOperator>	PhysicalOperator.inputs
protected List<PhysicalOperator>	PhysicalOperator.outputs

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

Modifier and Type	Method and Description
PhysicalOperator	PhysicalOperator.clone() Make a copy of this operator.

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

Modifier and Type	Method and Description
List<PhysicalOperator>	PhysicalOperator.getInputs()

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

Modifier and Type	Method and Description
protected void	PhysicalOperator.cloneHelper(PhysicalOperator op)
void	PhysicalOperator.copyAliasFrom(PhysicalOperator op)

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

Modifier and Type	Method and Description
void	PhysicalOperator.setInputs(List<PhysicalOperator> inputs)

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

Constructor and Description
PhysicalOperator(PhysicalOperator copy)

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

Constructor and Description
PhysicalOperator(OperatorKey k, int rp, List<PhysicalOperator> inp)
PhysicalOperator(OperatorKey k, List<PhysicalOperator> inp)

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

Subclasses of PhysicalOperator in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators

Modifier and Type	Class and Description
class	Add
class	BinaryComparisonOperator This is a base class for all binary comparison operators.
class	BinaryExpressionOperator A base class for all Binary expression operators.
class	ConstantExpression This class implements a Constant of any type.
class	Divide
class	EqualToExpr
class	ExpressionOperator A base class for all types of expressions.
class	GreaterThanExpr
class	GTOrEqualToExpr
class	LessThanExpr
class	LTOrEqualToExpr
class	Mod
class	Multiply
class	NotEqualToExpr
class	POAnd Boolean and operator.
class	POBinCond
class	POCast This is just a cast that converts DataByteArray into either String or Integer.
class	POIsNull
class	POMapLookUp
class	PONegative
class	PONot Boolean not operator.
class	POOr Boolean or operator.
class	POProject Implements the overloaded form of the project operator.
class	PORegexp
class	PORelationToExprProject Implements a specialized form of POProject which is used *ONLY* in the following case: This project is Project(*) introduced after a relational operator to supply a bag as output (as an expression).
class	POUserComparisonFunc
class	POUserFunc
class	Subtract
class	UnaryComparisonOperator This is a base class for all unary comparison operators.
class	UnaryExpressionOperator

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

Modifier and Type	Method and Description
PhysicalOperator	POUserFunc.getReferencedOperator()

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

Modifier and Type	Method and Description
void	POUserFunc.setReferencedOperator(PhysicalOperator referencedOperator)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators with type arguments of type PhysicalOperator

Constructor and Description
POUserFunc(OperatorKey k, int rp, List<PhysicalOperator> inp)
POUserFunc(OperatorKey k, int rp, List<PhysicalOperator> inp, FuncSpec funcSpec)
POUserFunc(OperatorKey k, int rp, List<PhysicalOperator> inp, FuncSpec funcSpec, EvalFunc func)

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

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with type parameters of type PhysicalOperator

Modifier and Type	Class and Description
class	XMLPhysicalPlanPrinter<P extends OperatorPlan<PhysicalOperator>>

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

Modifier and Type	Method and Description
void	PhysicalPlan.connect(PhysicalOperator from, PhysicalOperator to)
protected String[]	DotPOPrinter.getAttributes(PhysicalOperator op)
protected Collection<PhysicalPlan>	DotPOPrinter.getMultiOutputNestedPlans(PhysicalOperator op)
protected String	DotPOPrinter.getName(PhysicalOperator op)
protected Collection<PhysicalPlan>	DotPOPrinter.getNestedPlans(PhysicalOperator op)
void	PhysicalPlan.remove(PhysicalOperator op)
void	PhysicalPlan.replace(PhysicalOperator oldNode, PhysicalOperator newNode)
void	PhyPlanVisitor.visit(PhysicalOperator op)

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

Modifier and Type	Method and Description
void	PhysicalPlan.setOpMap(MultiMap<PhysicalOperator,PhysicalOperator> opmap)
void	PhysicalPlan.setOpMap(MultiMap<PhysicalOperator,PhysicalOperator> opmap)

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

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

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

Subclasses of PhysicalOperator in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Modifier and Type	Class and Description
class	POCollectedGroup The collected group operator is a special operator used when users give the hint 'using "collected"' in a group by clause.
class	POCounter This operator is part of the RANK operator implementation.
class	POCross Recover this class for nested cross operation.
class	PODemux The MapReduce Demultiplexer operator.
class	PODistinct Find the distinct set of tuples in a bag.
class	POFilter This is an implementation of the Filter operator.
class	POForEach
class	POFRJoin The operator models the join keys using the Local Rearrange operators which are configured with the plan specified by the user.
class	POGlobalRearrange Dummy operator to test MRCompiler.
class	POLimit
class	POLoad The load operator which is used in two ways: 1) As a local operator it can be used to load files 2) In the Map Reduce setting, it is used to create jobs from MapReduce operators which keep the loads and stores in the Map and Reduce Plans till the job is created
class	POLocalRearrange The local rearrange operator is a part of the co-group implementation.
class	POMergeCogroup
class	POMergeJoin This operator implements merge join algorithm to do map side joins.
class	PONative
class	POOptimizedForEach A specialized version of POForeach with the difference that in getNext(), it knows that "input" has already been attached by its input operator which SHOULD be POJoinPackage
class	POPackage The package operator that packages the globally rearranged tuples into output format as required by co-group.
class	POPartialAgg Do partial aggregation in map plan.
class	POPartitionRearrange The partition rearrange operator is a part of the skewed join implementation.
class	POPoissonSample
class	POPreCombinerLocalRearrange A specialized local rearrange operator which behaves like the regular local rearrange in the getNext() as far as getting its input and constructing the "key" out of the input.
class	PORank This operator is part of the RANK operator implementation.
class	POReservoirSample
class	POSkewedJoin The PhysicalOperator that represents a skewed join.
class	POSort This implementation is applicable for both the physical plan and for the local backend, as the conversion of physical to mapreduce would see the SORT operator and take necessary steps to convert it to a quantile and a sort job.
class	POSortedDistinct This operator is a variation of PODistinct, the input to this operator must be sorted already.
class	POSplit The MapReduce Split operator.
class	POStore The store operator which is used in two ways: 1) As a local operator it can be used to store files 2) In the Map Reduce setting, it is used to create jobs from MapReduce operators which keep the loads and stores in the Map and Reduce Plans till the job is created
class	POStream
class	POUnion The union operator that combines the two inputs into a single stream.

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

Modifier and Type	Field and Description
protected PhysicalOperator[]	POForEach.planLeafOps

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

Modifier and Type	Field and Description
protected List<PhysicalOperator>	POForEach.opsToBeReset

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

Modifier and Type	Method and Description
PhysicalOperator	POStream.clone()
PhysicalOperator	POPartialAgg.clone()
PhysicalOperator	POFilter.clone()

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

Modifier and Type	Method and Description
MultiMap<PhysicalOperator,PhysicalPlan>	POSkewedJoin.getJoinPlans()
List<PhysicalOperator>	POForEach.getOpsToBeReset()

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

Modifier and Type	Method and Description
void	POUnion.setInputs(List<PhysicalOperator> inputs)
void	POSkewedJoin.setJoinPlans(MultiMap<PhysicalOperator,PhysicalPlan> joinPlans)
void	POForEach.setOpsToBeReset(List<PhysicalOperator> opsToBeReset)

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

Constructor and Description
POCollectedGroup(OperatorKey k, int rp, List<PhysicalOperator> inp)
POCollectedGroup(OperatorKey k, List<PhysicalOperator> inp)
POCounter(OperatorKey k, int rp, List<PhysicalOperator> inputs)
POCounter(OperatorKey k, List<PhysicalOperator> inputs)
POCross(OperatorKey k, int rp, List<PhysicalOperator> inp)
POCross(OperatorKey k, List<PhysicalOperator> inp)
PODemux(OperatorKey k, int rp, List<PhysicalOperator> inp) Constructs an operator with the specified key, degree of parallelism and inputs.
PODemux(OperatorKey k, List<PhysicalOperator> inp) Constructs an operator with the specified key and inputs.
PODistinct(OperatorKey k, int rp, List<PhysicalOperator> inp)
PODistinct(OperatorKey k, List<PhysicalOperator> inp)
POFilter(OperatorKey k, int rp, List<PhysicalOperator> inputs)
POFilter(OperatorKey k, List<PhysicalOperator> inputs)
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)
POLimit(OperatorKey k, int rp, List<PhysicalOperator> inputs)
POLimit(OperatorKey k, List<PhysicalOperator> inputs)
POLocalRearrange(OperatorKey k, int rp, List<PhysicalOperator> inp)
POLocalRearrange(OperatorKey k, List<PhysicalOperator> inp)
POMergeCogroup(OperatorKey k, List<PhysicalOperator> inpPOs, POLocalRearrange[] lrs, int parallel)
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)
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)
POPackage(OperatorKey k, int rp, List<PhysicalOperator> inp)
POPackage(OperatorKey k, int rp, List<PhysicalOperator> inp, Packager pkgr)
POPackage(OperatorKey k, List<PhysicalOperator> inp)
POPartitionRearrange(OperatorKey k, int rp, List<PhysicalOperator> inp)
POPartitionRearrange(OperatorKey k, List<PhysicalOperator> inp)
POPreCombinerLocalRearrange(OperatorKey k, int rp, List<PhysicalOperator> inp)
POPreCombinerLocalRearrange(OperatorKey k, List<PhysicalOperator> inp)
PORank(OperatorKey k, int rp, List<PhysicalOperator> inp)
PORank(OperatorKey k, List<PhysicalOperator> inp)
POReservoirSample(OperatorKey k, int rp, List<PhysicalOperator> inp)
POReservoirSample(OperatorKey k, int rp, List<PhysicalOperator> inp, int numSamples)
POReservoirSample(OperatorKey k, List<PhysicalOperator> inp)
POSkewedJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, boolean[] flags)
POSkewedJoin(OperatorKey k, List<PhysicalOperator> inp, boolean[] flags)
POSortedDistinct(OperatorKey k, int rp, List<PhysicalOperator> inp)
POSortedDistinct(OperatorKey k, List<PhysicalOperator> inp)
POSplit(OperatorKey k, int rp, List<PhysicalOperator> inp) Constructs an operator with the specified key, degree of parallelism and inputs
POSplit(OperatorKey k, List<PhysicalOperator> inp) Constructs an operator with the specified key and inputs
POStore(OperatorKey k, int rp, List<PhysicalOperator> inp)
POUnion(OperatorKey k, int rp, List<PhysicalOperator> inp)
POUnion(OperatorKey k, List<PhysicalOperator> inp)

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

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

Modifier and Type	Method and Description
static <C extends PhysicalOperator> boolean	PlanHelper.containsPhysicalOperator(PhysicalPlan plan, Class<C> opClass)

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

Fields in org.apache.pig.backend.hadoop.executionengine.tez.plan with type parameters of type PhysicalOperator

Modifier and Type	Field and Description
Set<PhysicalOperator>	TezOperator.scalars

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

Subclasses of PhysicalOperator in org.apache.pig.backend.hadoop.executionengine.tez.plan.operator

Modifier and Type	Class and Description
class	POCounterStatsTez POCounterStatsTez is used to group counters from previous vertex POCounterTez tasks
class	POCounterTez
class	POFRJoinTez POFRJoinTez is used on the backend to load replicated table from Tez ShuffleUnorderedKVInput and load fragmented table from data pipeline.
class	POIdentityInOutTez POIdentityInOutTez is used to pass through tuples as is to next vertex from previous vertex's POLocalRearrangeTez.
class	POLocalRearrangeTez POLocalRearrangeTez is used to write to a Tez OrderedPartitionedKVOutput (shuffle) or UnorderedKVOutput (broadcast)
class	POPartitionRearrangeTez The partition rearrange operator is a part of the skewed join implementation.
class	PORankTez
class	POShuffledValueInputTez POShuffledValueInputTez is used read tuples from a Tez Intermediate output from a shuffle edge To be used with POValueOutputTez.
class	POShuffleTezLoad
class	POSimpleTezLoad POSimpleTezLoad is used on the backend to read tuples from a Tez MRInput
class	POStoreTez POStoreTez is used to write to a Tez MROutput
class	POValueInputTez POValueInputTez is used read tuples from a Tez Intermediate output from a 1-1 edge
class	POValueOutputTez

Uses of PhysicalOperator in org.apache.pig.backend.hadoop.executionengine.tez.runtime

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

Modifier and Type	Method and Description
protected void	PigProcessor.runPipeline(PhysicalOperator leaf)

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

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

Modifier and Type	Field and Description
protected Map<Operator,PhysicalOperator>	ExpToPhyTranslationVisitor.logToPhyMap

Constructor parameters in org.apache.pig.newplan.logical.expression with type arguments of type PhysicalOperator

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 PhysicalOperator in org.apache.pig.newplan.logical.relational

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

Modifier and Type	Field and Description
protected Map<Operator,PhysicalOperator>	LogToPhyTranslationVisitor.logToPhyMap

Methods in org.apache.pig.newplan.logical.relational that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Map<Operator,PhysicalOperator>	LogToPhyTranslationVisitor.getLogToPhyMap()

Uses of PhysicalOperator in org.apache.pig.pen

Methods in org.apache.pig.pen that return types with arguments of type PhysicalOperator

Modifier and Type	Method and Description
Map<PhysicalOperator,DataBag>	IllustratorAttacher.getDataMap()
Map<Operator,PhysicalOperator>	ExampleGenerator.getLogToPhyMap()
Map<PhysicalOperator,PhysicalOperator>	LocalMapReduceSimulator.getPhyToMRMap()
Map<PhysicalOperator,PhysicalOperator>	LocalMapReduceSimulator.getPhyToMRMap()

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

Modifier and Type	Method and Description
void	Illustrator.setEquivalenceClasses(LinkedList<IdentityHashSet<Tuple>> eqClasses, PhysicalOperator po)

Method parameters in org.apache.pig.pen with type arguments of type PhysicalOperator

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)
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)
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)

Constructor parameters in org.apache.pig.pen with type arguments of type PhysicalOperator

Constructor and Description
AugmentBaseDataVisitor(OperatorPlan plan, Map<Operator,PhysicalOperator> logToPhysMap, Map<LOLoad,DataBag> baseData, Map<Operator,DataBag> derivedData)
LineageTrimmingVisitor(LogicalPlan plan, Map<LOLoad,DataBag> baseData, ExampleGenerator eg, Map<Operator,PhysicalOperator> LogToPhyMap, PhysicalPlan physPlan, PigContext pc)