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.logicalLayer The logical operators that represent a pig script and tools for manipulating those operators. 
org.apache.pig.impl.plan   
org.apache.pig.impl.plan.optimizer   
org.apache.pig.pen.physicalOperators   
 

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
           
protected  Map<OperatorKey,MapRedResult> HExecutionEngine.materializedResults
           
 

Methods in org.apache.pig.backend.hadoop.executionengine that return types with arguments of type OperatorKey
 Map<OperatorKey,MapRedResult> HExecutionEngine.getMaterializedResults()
           
 

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)
           
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 inp)
           
POForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
           
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)
           
POGlobalRearrange(OperatorKey k)
           
POGlobalRearrange(OperatorKey k, int rp)
           
POGlobalRearrange(OperatorKey k, int rp, List inp)
           
POGlobalRearrange(OperatorKey k, List inp)
           
POJoinPackage(OperatorKey k, int rp, POPackage p, POForEach f)
           
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)
           
POLocalRearrangeForIllustrate(OperatorKey k)
           
POLocalRearrangeForIllustrate(OperatorKey k, int rp)
           
POLocalRearrangeForIllustrate(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POLocalRearrangeForIllustrate(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)
           
POMultiQueryPackage(OperatorKey k)
          Constructs an operator with the specified key.
POMultiQueryPackage(OperatorKey k, int rp)
          Constructs an operator with the specified key and degree of parallelism.
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.
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, List<PhysicalOperator> inp)
           
POPackageLite(OperatorKey k)
           
POPackageLite(OperatorKey k, int rp)
           
POPackageLite(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POPackageLite(OperatorKey k, List<PhysicalOperator> inp)
           
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)
           
PORead(OperatorKey k)
           
PORead(OperatorKey k, DataBag bag)
           
PORead(OperatorKey k, int rp)
           
PORead(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
PORead(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.logicalLayer
 

Methods in org.apache.pig.impl.logicalLayer that return OperatorKey
 OperatorKey LogicalOperator.getOperatorKey()
          Get the operator key for this operator.
 

Method parameters in org.apache.pig.impl.logicalLayer with type arguments of type OperatorKey
 LogicalPlan LogicalPlanBuilder.parse(String scope, String query, Map<LogicalOperator,LogicalPlan> aliases, Map<OperatorKey,LogicalOperator> opTable, Map<String,LogicalOperator> aliasOp, int start, Map<String,String> fileNameMap)
           
 LogicalPlan LogicalPlanBuilder.parse(String scope, String query, Map<LogicalOperator,LogicalPlan> aliases, Map<OperatorKey,LogicalOperator> opTable, Map<String,LogicalOperator> aliasOp, Map<String,String> fileNameMap)
           
 

Constructors in org.apache.pig.impl.logicalLayer with parameters of type OperatorKey
BinaryExpressionOperator(LogicalPlan plan, OperatorKey k)
           
BinaryExpressionOperator(LogicalPlan plan, OperatorKey k, int rp)
           
ExpressionOperator(LogicalPlan plan, OperatorKey k)
           
ExpressionOperator(LogicalPlan plan, OperatorKey k, int rp)
           
LOAdd(LogicalPlan plan, OperatorKey k)
           
LOAnd(LogicalPlan plan, OperatorKey k)
           
LOBinCond(LogicalPlan plan, OperatorKey k)
           
LOCast(LogicalPlan plan, OperatorKey k, byte type)
           
LOCogroup(LogicalPlan plan, OperatorKey k, MultiMap<LogicalOperator,LogicalPlan> groupByPlans, boolean[] isInner)
           
LOCogroup(LogicalPlan plan, OperatorKey k, MultiMap<LogicalOperator,LogicalPlan> groupByPlans, LOCogroup.GROUPTYPE type, boolean[] isInner)
           
LOConst(LogicalPlan plan, OperatorKey k, Object value)
           
LOCross(LogicalPlan plan, OperatorKey k)
           
LODefine(LogicalPlan plan, OperatorKey key)
           
LODistinct(LogicalPlan plan, OperatorKey k)
           
LODivide(LogicalPlan plan, OperatorKey k)
           
LOEqual(LogicalPlan plan, OperatorKey k)
           
LOFilter(LogicalPlan plan, OperatorKey k, LogicalPlan comparisonPlan)
           
LOForEach(LogicalPlan plan, OperatorKey k, ArrayList<LogicalPlan> foreachPlans, ArrayList<Boolean> flattenList)
           
LOForEach(LogicalPlan plan, OperatorKey k, ArrayList<LogicalPlan> foreachPlans, ArrayList<Boolean> flattenList, ArrayList<Schema> userDefinedSchemaList)
           
LOGenerate(LogicalPlan plan, OperatorKey key, ArrayList<LogicalPlan> generatePlans, ArrayList<Boolean> flatten)
           
LOGenerate(LogicalPlan plan, OperatorKey key, ArrayList<LogicalPlan> generatePlans, ArrayList<Boolean> flatten, ArrayList<Schema> userDefinedSchemaList)
           
LOGenerate(LogicalPlan plan, OperatorKey key, LogicalPlan generatePlan, boolean flatten)
           
LogicalOperator(LogicalPlan plan, OperatorKey k)
          Equivalent to LogicalOperator(k, 0).
LogicalOperator(LogicalPlan plan, OperatorKey k, int rp)
           
LOGreaterThan(LogicalPlan plan, OperatorKey k)
           
LOGreaterThanEqual(LogicalPlan plan, OperatorKey k)
           
LOIsNull(LogicalPlan plan, OperatorKey k)
           
LOJoin(LogicalPlan plan, OperatorKey k, MultiMap<LogicalOperator,LogicalPlan> joinPlans, LOJoin.JOINTYPE jt, boolean[] isInner)
           
LOLesserThan(LogicalPlan plan, OperatorKey k)
           
LOLesserThanEqual(LogicalPlan plan, OperatorKey k)
           
LOLimit(LogicalPlan plan, OperatorKey k, long limit)
           
LOLoad(LogicalPlan plan, OperatorKey key, FileSpec inputFileSpec, org.apache.hadoop.conf.Configuration conf)
           
LOMapLookup(LogicalPlan plan, OperatorKey key, String mapKey, byte valueType, Schema valueSchema)
           
LOMod(LogicalPlan plan, OperatorKey k)
           
LOMultiply(LogicalPlan plan, OperatorKey k)
           
LONative(LogicalPlan plan, OperatorKey k, String nativeJar, String[] parameters)
           
LONegative(LogicalPlan plan, OperatorKey k)
           
LONot(LogicalPlan plan, OperatorKey k)
           
LONotEqual(LogicalPlan plan, OperatorKey k)
           
LOOr(LogicalPlan plan, OperatorKey k)
           
LOProject(LogicalPlan plan, OperatorKey key, LogicalOperator exp, Integer projection)
           
LOProject(LogicalPlan plan, OperatorKey key, LogicalOperator exp, List<Integer> projection)
           
LORegexp(LogicalPlan plan, OperatorKey key)
           
LOSort(LogicalPlan plan, OperatorKey key, List<LogicalPlan> sortColPlans, List<Boolean> ascCols, FuncSpec sortFunc)
           
LOSplit(LogicalPlan plan, OperatorKey key, ArrayList<LogicalOperator> outputs)
           
LOSplitOutput(LogicalPlan plan, OperatorKey key, int index, LogicalPlan condPlan)
           
LOStore(LogicalPlan plan, OperatorKey key, FileSpec outputFileSpec, String alias)
           
LOStream(LogicalPlan plan, OperatorKey k, LogicalOperator input, ExecutableManager exeManager, StreamingCommand cmd)
          Create a new LOStream with the given command.
LOSubtract(LogicalPlan plan, OperatorKey k)
           
LOUnion(LogicalPlan plan, OperatorKey k)
           
LOUserFunc(LogicalPlan plan, OperatorKey k, FuncSpec funcSpec, byte returnType)
           
RelationalOperator(LogicalPlan plan, OperatorKey k)
           
RelationalOperator(LogicalPlan plan, OperatorKey k, int rp)
           
UnaryExpressionOperator(LogicalPlan plan, OperatorKey k)
           
UnaryExpressionOperator(LogicalPlan plan, OperatorKey k, int rp)
           
 

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)
           
 

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

Constructors in org.apache.pig.impl.plan.optimizer with parameters of type OperatorKey
RuleOperator(Class clazz, OperatorKey k)
           
RuleOperator(Class clazz, RuleOperator.NodeType nodeType, OperatorKey k)
           
 

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

Constructors in org.apache.pig.pen.physicalOperators with parameters of type OperatorKey
POCogroup(OperatorKey k)
           
POCogroup(OperatorKey k, int rp)
           
POCogroup(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POCogroup(OperatorKey k, List<PhysicalOperator> inp)
           
POCounter(OperatorKey k)
           
POCounter(OperatorKey k, int rp)
           
POCounter(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POCounter(OperatorKey k, List<PhysicalOperator> inp)
           
POCross(OperatorKey k)
           
POCross(OperatorKey k, int rp)
           
POCross(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POCross(OperatorKey k, List<PhysicalOperator> inp)
           
POSplit(OperatorKey k)
           
POSplit(OperatorKey k, int rp)
           
POSplit(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POSplit(OperatorKey k, List<PhysicalOperator> inp)
           
POSplitOutput(OperatorKey k)
           
POSplitOutput(OperatorKey k, int rp)
           
POSplitOutput(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POSplitOutput(OperatorKey k, List<PhysicalOperator> inp)
           
POStreamLocal(OperatorKey k, ExecutableManager executableManager, StreamingCommand command, Properties properties)
           
 



Copyright © ${year} The Apache Software Foundation