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

Packages that use OperatorKey

Package	Description
org.apache.pig.backend.hadoop.executionengine
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
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.relationalOperators
org.apache.pig.backend.hadoop.executionengine.physicalLayer.util
org.apache.pig.backend.hadoop.executionengine.spark.operator
org.apache.pig.backend.hadoop.executionengine.spark.plan
org.apache.pig.backend.hadoop.executionengine.tez.plan
org.apache.pig.backend.hadoop.executionengine.tez.plan.operator
org.apache.pig.backend.hadoop.executionengine.util
org.apache.pig.data	This package contains implementations of Pig specific data types as well as support functions for reading, writing, and using all Pig data types.
org.apache.pig.impl.plan

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

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

Modifier and Type	Field and Description
protected Map<OperatorKey,OperatorKey>	HExecutionEngine.logicalToPhysicalKeys
protected Map<OperatorKey,OperatorKey>	HExecutionEngine.logicalToPhysicalKeys

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

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

Modifier and Type	Method and Description
List<OperatorKey>	PigSplit.getTargetOps()

Method parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with type arguments of type OperatorKey

Modifier and Type	Method and Description
protected List<org.apache.hadoop.mapreduce.InputSplit>	PigInputFormat.getPigSplits(List<org.apache.hadoop.mapreduce.InputSplit> oneInputSplits, int inputIndex, ArrayList<OperatorKey> targetOps, long blockSize, boolean combinable, org.apache.hadoop.conf.Configuration conf)

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

Constructor and Description
MapReduceOper(OperatorKey k)
NativeMapReduceOper(OperatorKey k, String mrJar, String[] parameters)

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

Constructor and Description
PigSplit(org.apache.hadoop.mapreduce.InputSplit[] wrappedSplits, int inputIndex, List<OperatorKey> targetOps, int splitIndex)

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

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

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

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

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

Constructor and Description
Add(OperatorKey k)
Add(OperatorKey k, int rp)
BinaryComparisonOperator(OperatorKey k)
BinaryComparisonOperator(OperatorKey k, int rp)
BinaryExpressionOperator(OperatorKey k)
BinaryExpressionOperator(OperatorKey k, int rp)
ConstantExpression(OperatorKey k)
ConstantExpression(OperatorKey k, int rp)
Divide(OperatorKey k)
Divide(OperatorKey k, int rp)
EqualToExpr(OperatorKey k)
EqualToExpr(OperatorKey k, int rp)
ExpressionOperator(OperatorKey k)
ExpressionOperator(OperatorKey k, int rp)
GreaterThanExpr(OperatorKey k)
GreaterThanExpr(OperatorKey k, int rp)
GTOrEqualToExpr(OperatorKey k)
GTOrEqualToExpr(OperatorKey k, int rp)
LessThanExpr(OperatorKey k)
LessThanExpr(OperatorKey k, int rp)
LTOrEqualToExpr(OperatorKey k)
LTOrEqualToExpr(OperatorKey k, int rp)
Mod(OperatorKey k)
Mod(OperatorKey k, int rp)
Multiply(OperatorKey k)
Multiply(OperatorKey k, int rp)
NotEqualToExpr(OperatorKey k)
NotEqualToExpr(OperatorKey k, int rp)
POAnd(OperatorKey k)
POAnd(OperatorKey k, int rp)
POBinCond(OperatorKey k)
POBinCond(OperatorKey k, int rp)
POBinCond(OperatorKey k, int rp, ExpressionOperator cond, ExpressionOperator lhs, ExpressionOperator rhs)
POCast(OperatorKey k)
POCast(OperatorKey k, int rp)
POIsNull(OperatorKey k)
POIsNull(OperatorKey k, int rp)
POIsNull(OperatorKey k, int rp, ExpressionOperator in)
POMapLookUp(OperatorKey k)
POMapLookUp(OperatorKey k, int rp)
POMapLookUp(OperatorKey k, int rp, String key)
PONegative(OperatorKey k)
PONegative(OperatorKey k, int rp)
PONegative(OperatorKey k, int rp, ExpressionOperator input)
PONot(OperatorKey k)
PONot(OperatorKey k, int rp)
POOr(OperatorKey k)
POOr(OperatorKey k, int rp)
POProject(OperatorKey k)
POProject(OperatorKey k, int rp)
POProject(OperatorKey k, int rp, ArrayList<Integer> cols)
POProject(OperatorKey k, int rp, int col)
PORegexp(OperatorKey k)
PORegexp(OperatorKey k, int rp)
PORelationToExprProject(OperatorKey k)
PORelationToExprProject(OperatorKey k, int rp)
PORelationToExprProject(OperatorKey k, int rp, ArrayList<Integer> cols)
PORelationToExprProject(OperatorKey k, int rp, int col)
POUserComparisonFunc(OperatorKey k, int rp, List inp, FuncSpec funcSpec)
POUserComparisonFunc(OperatorKey k, int rp, List inp, FuncSpec funcSpec, ComparisonFunc func)
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)
Subtract(OperatorKey k)
Subtract(OperatorKey k, int rp)
UnaryComparisonOperator(OperatorKey k)
UnaryComparisonOperator(OperatorKey k, int rp)
UnaryExpressionOperator(OperatorKey k)
UnaryExpressionOperator(OperatorKey k, int rp)

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

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

Constructor and Description
POBroadcastSpark(OperatorKey k)
POCollectedGroup(OperatorKey k)
POCollectedGroup(OperatorKey k, int rp)
POCollectedGroup(OperatorKey k, int rp, List<PhysicalOperator> inp)
POCollectedGroup(OperatorKey k, List<PhysicalOperator> inp)
POCounter(OperatorKey k)
POCounter(OperatorKey k, int rp)
POCounter(OperatorKey k, int rp, List<PhysicalOperator> inputs)
POCounter(OperatorKey operatorKey, int requestedParallelism, List inp, List<PhysicalPlan> counterPlans, List<Boolean> ascendingCol)
POCounter(OperatorKey k, List<PhysicalOperator> inputs)
POCross(OperatorKey k)
POCross(OperatorKey k, int rp)
POCross(OperatorKey k, int rp, List<PhysicalOperator> inp)
POCross(OperatorKey k, List<PhysicalOperator> inp)
PODemux(OperatorKey k) Constructs an operator with the specified key.
PODemux(OperatorKey k, int rp) Constructs an operator with the specified key and degree of parallelism.
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)
PODistinct(OperatorKey k, int rp)
PODistinct(OperatorKey k, int rp, List<PhysicalOperator> inp)
PODistinct(OperatorKey k, List<PhysicalOperator> inp)
POFilter(OperatorKey k)
POFilter(OperatorKey k, int rp)
POFilter(OperatorKey k, int rp, List<PhysicalOperator> inputs)
POFilter(OperatorKey k, List<PhysicalOperator> inputs)
POForEach(OperatorKey k)
POForEach(OperatorKey k, int rp)
POForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
POForEach(OperatorKey operatorKey, int requestedParallelism, List<PhysicalPlan> innerPlans, List<Boolean> flattenList, Schema schema)
POForEach(OperatorKey k, List inp)
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)
POGlobalRearrange(OperatorKey k)
POGlobalRearrange(OperatorKey k, int rp)
POGlobalRearrange(OperatorKey k, int rp, List inp)
POGlobalRearrange(OperatorKey k, List inp)
POLimit(OperatorKey k)
POLimit(OperatorKey k, int rp)
POLimit(OperatorKey k, int rp, List<PhysicalOperator> inputs)
POLimit(OperatorKey k, List<PhysicalOperator> inputs)
POLoad(OperatorKey k)
POLoad(OperatorKey k, FileSpec lFile)
POLoad(OperatorKey k, int rp, FileSpec lFile)
POLoad(OperatorKey k, LoadFunc lf)
POLocalRearrange(OperatorKey k)
POLocalRearrange(OperatorKey k, int rp)
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)
PONative(OperatorKey k)
POOptimizedForEach(OperatorKey k)
POOptimizedForEach(OperatorKey k, int rp)
POOptimizedForEach(OperatorKey k, int rp, List inp)
POOptimizedForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
POOptimizedForEach(OperatorKey k, List inp)
POPackage(OperatorKey k)
POPackage(OperatorKey k, int rp)
POPackage(OperatorKey k, int rp, List<PhysicalOperator> inp)
POPackage(OperatorKey k, int rp, List<PhysicalOperator> inp, Packager pkgr)
POPackage(OperatorKey k, List<PhysicalOperator> inp)
POPartialAgg(OperatorKey k)
POPartialAgg(OperatorKey k, boolean isGroupAll)
POPartitionRearrange(OperatorKey k)
POPartitionRearrange(OperatorKey k, int rp)
POPartitionRearrange(OperatorKey k, int rp, List<PhysicalOperator> inp)
POPartitionRearrange(OperatorKey k, List<PhysicalOperator> inp)
POPoissonSample(OperatorKey k, int rp, int sr, float hp, long tm)
POPreCombinerLocalRearrange(OperatorKey k)
POPreCombinerLocalRearrange(OperatorKey k, int rp)
POPreCombinerLocalRearrange(OperatorKey k, int rp, List<PhysicalOperator> inp)
POPreCombinerLocalRearrange(OperatorKey k, List<PhysicalOperator> inp)
PORank(OperatorKey k)
PORank(OperatorKey k, int rp)
PORank(OperatorKey k, int rp, List<PhysicalOperator> inp)
PORank(OperatorKey operatorKey, int requestedParallelism, List inp, List<PhysicalPlan> rankPlans, List<Boolean> ascendingCol)
PORank(OperatorKey k, List<PhysicalOperator> inp)
POReservoirSample(OperatorKey k)
POReservoirSample(OperatorKey k, int rp)
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)
POSkewedJoin(OperatorKey k, int rp)
POSkewedJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, boolean[] flags)
POSkewedJoin(OperatorKey k, List<PhysicalOperator> inp, boolean[] flags)
POSort(OperatorKey k)
POSort(OperatorKey k, int rp)
POSort(OperatorKey k, int rp, List inp)
POSort(OperatorKey k, int rp, List inp, List<PhysicalPlan> sortPlans, List<Boolean> mAscCols, POUserComparisonFunc mSortFunc)
POSort(OperatorKey k, List inp)
POSortedDistinct(OperatorKey k)
POSortedDistinct(OperatorKey k, int rp)
POSortedDistinct(OperatorKey k, int rp, List<PhysicalOperator> inp)
POSortedDistinct(OperatorKey k, List<PhysicalOperator> inp)
POSplit(OperatorKey k) Constructs an operator with the specified key
POSplit(OperatorKey k, int rp) Constructs an operator with the specified key and degree of parallelism
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)
POStore(OperatorKey k, int rp)
POStore(OperatorKey k, int rp, List<PhysicalOperator> inp)
POStream(OperatorKey k, ExecutableManager executableManager, StreamingCommand command, Properties properties)
POUnion(OperatorKey k)
POUnion(OperatorKey k, int rp)
POUnion(OperatorKey k, int rp, List<PhysicalOperator> inp)
POUnion(OperatorKey k, List<PhysicalOperator> inp)

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

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

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

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

Constructors in org.apache.pig.backend.hadoop.executionengine.spark.operator with parameters of type OperatorKey

Constructor and Description
NativeSparkOperator(OperatorKey k, String sparkJar, String[] parameters)
POPoissonSampleSpark(OperatorKey k, int rp, int sr, float hp, long tm)
POReduceBySpark(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened, POPackage pkg, POLocalRearrange lr)

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

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

Modifier and Type	Method and Description
MultiMap<OperatorKey,OperatorKey>	SparkOperator.getMultiQueryOptimizeConnectionItem()
MultiMap<OperatorKey,OperatorKey>	SparkOperator.getMultiQueryOptimizeConnectionItem()

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

Modifier and Type	Method and Description
void	SparkOperator.addMultiQueryOptimizeConnectionItem(OperatorKey to, OperatorKey from)

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

Constructor and Description
SparkOperator(OperatorKey k)

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

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

Modifier and Type	Field and Description
Map<OperatorKey,TezEdgeDescriptor>	TezOperator.inEdges
Map<OperatorKey,TezEdgeDescriptor>	TezOperator.outEdges

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

Modifier and Type	Method and Description
OperatorKey	TezOperator.getSplitParent()

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

Modifier and Type	Method and Description
List<OperatorKey>	TezOperator.VertexGroupInfo.getInputs()
List<OperatorKey>	TezOperator.getUnionMembers()
List<OperatorKey>	TezOperator.getVertexGroupMembers()
Map<OperatorKey,OperatorKey>	TezOperator.getVertexGroupStores()
Map<OperatorKey,OperatorKey>	TezOperator.getVertexGroupStores()

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

Modifier and Type	Method and Description
void	TezOperator.VertexGroupInfo.addInput(OperatorKey input)
void	TezOperator.addUnionPredecessor(OperatorKey unionPredecessor)
void	TezOperator.addVertexGroupStore(OperatorKey storeKey, OperatorKey vertexGroupKey)
boolean	TezOperator.VertexGroupInfo.removeInput(OperatorKey input)
void	TezOperator.removeVertexGroupStore(OperatorKey vertexGroupKey)
void	TezOperator.setSplitParent(OperatorKey splitParent)

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

Modifier and Type	Method and Description
void	TezOperator.setVertexGroupMembers(List<OperatorKey> vertexGroupMembers)

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

Constructor and Description
TezOperator(OperatorKey k)
TezPlanContainerNode(OperatorKey k, TezOperPlan tezPlan)

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

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

Constructor and Description
NativeTezOper(OperatorKey k, String tezJar, String[] parameters)
POCounterStatsTez(OperatorKey k)
POIdentityInOutTez(OperatorKey k, POLocalRearrange inputRearrange, String inputKey)
POLocalRearrangeTez(OperatorKey k)
POLocalRearrangeTez(OperatorKey k, int rp)
POPartitionRearrangeTez(OperatorKey k)
POPartitionRearrangeTez(OperatorKey k, int rp)
POShuffledValueInputTez(OperatorKey k)
POSimpleTezLoad(OperatorKey k, LoadFunc loader)
POStoreTez(OperatorKey k)
POValueInputTez(OperatorKey k)
POValueOutputTez(OperatorKey k)

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

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

Modifier and Type	Method and Description
static OperatorKey	CombinerOptimizerUtil.createOperatorKey(String scope)

Uses of OperatorKey in org.apache.pig.data

Fields in org.apache.pig.data with type parameters of type OperatorKey

Modifier and Type	Field and Description
List<OperatorKey>	TargetedTuple.targetOps

Methods in org.apache.pig.data that return types with arguments of type OperatorKey

Modifier and Type	Method and Description
List<OperatorKey>	TargetedTuple.getTargetOps()

Method parameters in org.apache.pig.data with type arguments of type OperatorKey

Modifier and Type	Method and Description
void	TargetedTuple.setTargetOps(List<OperatorKey> targetOps)

Constructor parameters in org.apache.pig.data with type arguments of type OperatorKey

Constructor and Description
TargetedTuple(Tuple t, List<OperatorKey> targetOps)

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

Fields in org.apache.pig.impl.plan declared as OperatorKey

Modifier and Type	Field and Description
protected OperatorKey	Operator.mKey OperatorKey associated with this operator.

Fields in org.apache.pig.impl.plan with type parameters of type OperatorKey

Modifier and Type	Field and Description
protected Map<OperatorKey,E>	OperatorPlan.mKeys
protected Map<E,OperatorKey>	OperatorPlan.mOps

Methods in org.apache.pig.impl.plan that return OperatorKey

Modifier and Type	Method and Description
static OperatorKey	OperatorKey.fromString(String op)
static OperatorKey	OperatorKey.genOpKey(String scope) Utility function for creating operator keys.
OperatorKey	Operator.getOperatorKey() Get the operator key for this operator.
OperatorKey	OperatorPlan.getOperatorKey(E op) Given an operator, find its OperatorKey.

Methods in org.apache.pig.impl.plan that return types with arguments of type OperatorKey

Modifier and Type	Method and Description
Map<OperatorKey,E>	OperatorPlan.getKeys() Get the map of operator key and associated operators

Methods in org.apache.pig.impl.plan with parameters of type OperatorKey

Modifier and Type	Method and Description
int	OperatorKey.compareTo(OperatorKey o)
E	OperatorPlan.getOperator(OperatorKey opKey) Given an OperatorKey, find the associated operator.

Constructors in org.apache.pig.impl.plan with parameters of type OperatorKey

Constructor and Description
Operator(OperatorKey k)