public class POSortedDistinct extends PODistinct
PhysicalOperator.OriginalLocation
customPartitioner
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POSortedDistinct(OperatorKey k) |
POSortedDistinct(OperatorKey k,
int rp) |
POSortedDistinct(OperatorKey k,
int rp,
List<PhysicalOperator> inp) |
POSortedDistinct(OperatorKey k,
List<PhysicalOperator> inp) |
Modifier and Type | Method and Description |
---|---|
Result |
getNextTuple() |
String |
name() |
clone, getCustomPartitioner, illustratorMarkup, isBlocking, reset, setCustomPartitioner, supportsMultipleInputs, supportsMultipleOutputs, visit
addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isEndOfAllInput, isInputAttached, processInput, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
public POSortedDistinct(OperatorKey k, int rp, List<PhysicalOperator> inp)
public POSortedDistinct(OperatorKey k, int rp)
public POSortedDistinct(OperatorKey k, List<PhysicalOperator> inp)
public POSortedDistinct(OperatorKey k)
public Result getNextTuple() throws ExecException
getNextTuple
in class PODistinct
ExecException
public String name()
name
in class PODistinct
Copyright © 2007-2017 The Apache Software Foundation