org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
Class POSortedDistinct
java.lang.Object
org.apache.pig.impl.plan.Operator<PhyPlanVisitor>
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSortedDistinct
- All Implemented Interfaces:
- Serializable, Cloneable, Comparable<Operator>, Illustrable
public class POSortedDistinct
- extends PODistinct
This operator is a variation of PODistinct, the input to this operator
must be sorted already.
- See Also:
- Serialized Form
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
alias, dummyBag, dummyBool, dummyDBA, dummyDouble, dummyFloat, dummyInt, dummyLong, dummyMap, dummyString, dummyTuple, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, resultType |
Fields inherited from class org.apache.pig.impl.plan.Operator |
mKey |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
attachInput, cloneHelper, detachInput, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isInputAttached, processInput, setAccumEnd, setAccumStart, setAccumulative, setAlias, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType |
POSortedDistinct
public POSortedDistinct(OperatorKey k,
int rp,
List<PhysicalOperator> inp)
POSortedDistinct
public POSortedDistinct(OperatorKey k,
int rp)
POSortedDistinct
public POSortedDistinct(OperatorKey k,
List<PhysicalOperator> inp)
POSortedDistinct
public POSortedDistinct(OperatorKey k)
getNext
public Result getNext(Tuple t)
throws ExecException
- Overrides:
getNext
in class PODistinct
- Throws:
ExecException
name
public String name()
- Overrides:
name
in class PODistinct
Copyright © ${year} The Apache Software Foundation