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

Packages that use PhysicalOperator
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.experimental.logical.expression   
org.apache.pig.experimental.logical.relational   
org.apache.pig.pen   
org.apache.pig.pen.physicalOperators   
 

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

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type PhysicalOperator
protected  void PigMapReduce.MapWithPartitionIndex.runPipeline(PhysicalOperator leaf)
           
protected  void PigMapReduce.Reduce.runPipeline(PhysicalOperator leaf)
           
protected  void PigMapBase.runPipeline(PhysicalOperator leaf)
           
 

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with type arguments of type PhysicalOperator
UDFFinishVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)
           
 

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

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with type arguments of type PhysicalOperator
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
protected  List<PhysicalOperator> PhysicalOperator.inputs
           
protected  Map<LogicalOperator,PhysicalOperator> LogToPhyTranslationVisitor.logToPhyMap
           
protected  List<PhysicalOperator> PhysicalOperator.outputs
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer that return PhysicalOperator
 PhysicalOperator PhysicalOperator.clone()
          Make a deep copy of this operator.
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer that return types with arguments of type PhysicalOperator
 List<PhysicalOperator> PhysicalOperator.getInputs()
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer with parameters of type PhysicalOperator
protected  void PhysicalOperator.cloneHelper(PhysicalOperator op)
           
 

Method parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer with type arguments of type PhysicalOperator
 void PhysicalOperator.setInputs(List<PhysicalOperator> inputs)
           
 

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer with type arguments of type PhysicalOperator
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
 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
           
 

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators with type arguments of type PhysicalOperator
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
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with parameters of type PhysicalOperator
 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)
           
 

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with type arguments of type PhysicalOperator
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
 class POCollectedGroup
          The collected group operator is a special operator used when users give the hint 'using "collected"' in a group by clause.
 class POCombinerPackage
          The package operator that packages the globally rearranged tuples into output format after the combiner stage.
 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 POJoinPackage
           
 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 POLocalRearrangeForIllustrate
          The local rearrange operator is a part of the co-group implementation.
 class POMergeJoin
          This operator implements merge join algorithm to do map side joins.
 class POMultiQueryPackage
          The package operator that packages the globally rearranged tuples into output format as required by multi-query de-multiplexer.
 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 POPackageLite
          This package operator is a specialization of POPackage operator used for the specific case of the order by query.
 class POPartitionRearrange
          The partition rearrange operator is a part of the skewed join implementation.
 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 PORead
          This operator is used to read tuples from a databag in memory.
 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
protected  PhysicalOperator[] POForEach.planLeafOps
           
 

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type parameters of type PhysicalOperator
protected  List<PhysicalOperator> POForEach.opsToBeReset
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return types with arguments of type PhysicalOperator
 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
 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
POCollectedGroup(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POCollectedGroup(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)
           
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)
           
POLocalRearrangeForIllustrate(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POLocalRearrangeForIllustrate(OperatorKey k, List<PhysicalOperator> inp)
           
POMergeJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, MultiMap<PhysicalOperator,PhysicalPlan> inpPlans, List<List<Byte>> keyTypes)
           
POMergeJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, MultiMap<PhysicalOperator,PhysicalPlan> inpPlans, List<List<Byte>> keyTypes)
           
POMultiQueryPackage(OperatorKey k, int rp, List<PhysicalOperator> inp)
          Constructs an operator with the specified key, degree of parallelism and inputs.
POMultiQueryPackage(OperatorKey k, List<PhysicalOperator> inp)
          Constructs an operator with the specified key and inputs.
POPackage(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POPackage(OperatorKey k, List<PhysicalOperator> inp)
           
POPackageLite(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POPackageLite(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)
           
PORead(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
PORead(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.experimental.logical.expression
 

Fields in org.apache.pig.experimental.logical.expression with type parameters of type PhysicalOperator
protected  Map<Operator,PhysicalOperator> ExpToPhyTranslationVisitor.logToPhyMap
           
 

Constructor parameters in org.apache.pig.experimental.logical.expression with type arguments of type PhysicalOperator
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.experimental.logical.relational
 

Fields in org.apache.pig.experimental.logical.relational with type parameters of type PhysicalOperator
protected  Map<Operator,PhysicalOperator> LogToPhyTranslationVisitor.logToPhyMap
           
 

Uses of PhysicalOperator in org.apache.pig.pen
 

Methods in org.apache.pig.pen that return types with arguments of type PhysicalOperator
 Map<LogicalOperator,PhysicalOperator> LocalLogToPhyTranslationVisitor.getLogToPhyMap()
           
 

Constructor parameters in org.apache.pig.pen with type arguments of type PhysicalOperator
DerivedDataVisitor(LogicalOperator op, PigContext pc, Map<LOLoad,DataBag> baseData, Map<LogicalOperator,PhysicalOperator> logToPhyMap, PhysicalPlan physPlan)
           
DerivedDataVisitor(LogicalPlan plan, PigContext pc, Map<LOLoad,DataBag> baseData, Map<LogicalOperator,PhysicalOperator> logToPhyMap, PhysicalPlan physPlan)
           
LineageTrimmingVisitor(LogicalPlan plan, Map<LOLoad,DataBag> baseData, Map<LogicalOperator,PhysicalOperator> LogToPhyMap, PhysicalPlan physPlan, PigContext pc)
           
 

Uses of PhysicalOperator in org.apache.pig.pen.physicalOperators
 

Subclasses of PhysicalOperator in org.apache.pig.pen.physicalOperators
 class POCogroup
          This is a local implementation of Cogroup.
 class POCounter
           
 class POCross
          This is a local implementation of the cross.
 class POSplitOutput
           
 class POStreamLocal
           
 

Constructor parameters in org.apache.pig.pen.physicalOperators with type arguments of type PhysicalOperator
POCogroup(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POCogroup(OperatorKey k, List<PhysicalOperator> inp)
           
POCounter(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POCounter(OperatorKey k, List<PhysicalOperator> inp)
           
POCross(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POCross(OperatorKey k, List<PhysicalOperator> inp)
           
POSplit(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POSplit(OperatorKey k, List<PhysicalOperator> inp)
           
POSplitOutput(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POSplitOutput(OperatorKey k, List<PhysicalOperator> inp)
           
 



Copyright © ${year} The Apache Software Foundation