org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
Class POSortedDistinct

java.lang.Object
  extended by org.apache.pig.impl.plan.Operator<PhyPlanVisitor>
      extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
          extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct
              extended by 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

Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
PhysicalOperator.OriginalLocation
 
Field Summary
 
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct
customPartitioner
 
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, requestedParallelism, res, resultType
 
Fields inherited from class org.apache.pig.impl.plan.Operator
mKey
 
Constructor Summary
POSortedDistinct(OperatorKey k)
           
POSortedDistinct(OperatorKey k, int rp)
           
POSortedDistinct(OperatorKey k, int rp, List<PhysicalOperator> inp)
           
POSortedDistinct(OperatorKey k, List<PhysicalOperator> inp)
           
 
Method Summary
 Result getNextTuple()
           
 String name()
           
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct
clone, getCustomPartitioner, illustratorMarkup, isBlocking, reset, setCustomPartitioner, supportsMultipleInputs, supportsMultipleOutputs, visit
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isInputAttached, processInput, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType
 
Methods inherited from class org.apache.pig.impl.plan.Operator
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
 
Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

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)
Method Detail

getNextTuple

public Result getNextTuple()
                    throws ExecException
Overrides:
getNextTuple in class PODistinct
Throws:
ExecException

name

public String name()
Overrides:
name in class PODistinct


Copyright © 2007-2012 The Apache Software Foundation