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

Packages that use OperatorKey

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

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

List<OperatorKey>

PigSplit.getTargetOps()

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

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

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

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

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

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

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)

POPartitionRearrange(OperatorKey k)

POPartitionRearrange(OperatorKey k, int rp)

POPartitionRearrange(OperatorKey k, int rp, List<PhysicalOperator> inp)

POPartitionRearrange(OperatorKey k, List<PhysicalOperator> inp)

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)

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.data

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

List<OperatorKey>

TargetedTuple.targetOps

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

List<OperatorKey>

TargetedTuple.getTargetOps()

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

void	TargetedTuple.setTargetOps(List<OperatorKey> targetOps)

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

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

protected OperatorKey

Operator.mKey OperatorKey associated with this operator.

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

protected Map<OperatorKey,E>	OperatorPlan.mKeys
protected Map<E,OperatorKey>	OperatorPlan.mOps

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

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

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

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

Operator(OperatorKey k)