public class POSort extends PhysicalOperator
Modifier and Type | Class and Description |
---|---|
class |
POSort.SortComparator |
class |
POSort.UDFSortComparator |
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
boolean |
isUDFComparatorUsed |
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
POSort |
clone()
Make a copy of this operator.
|
long |
getLimit() |
List<Boolean> |
getMAscCols() |
Comparator<Tuple> |
getMComparator() |
POUserComparisonFunc |
getMSortFunc() |
Result |
getNextTuple() |
List<PhysicalPlan> |
getSortPlans() |
Tuple |
illustratorMarkup(Object in,
Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
boolean |
isBlocking()
A blocking operator should override this to return true.
|
boolean |
isLimited() |
String |
name() |
void |
reset()
Reset internal state in an operator.
|
void |
setLimit(long l) |
void |
setMSortFunc(POUserComparisonFunc sortFunc) |
void |
setSortPlans(List<PhysicalPlan> sortPlans) |
boolean |
supportsMultipleInputs()
Indicates whether this operator supports multiple inputs.
|
boolean |
supportsMultipleOutputs()
Indicates whether this operator supports multiple outputs.
|
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
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 POSort(OperatorKey k, int rp, List inp, List<PhysicalPlan> sortPlans, List<Boolean> mAscCols, POUserComparisonFunc mSortFunc)
public POSort(OperatorKey k, int rp, List inp)
public POSort(OperatorKey k, int rp)
public POSort(OperatorKey k, List inp)
public POSort(OperatorKey k)
public String name()
name
in class Operator<PhyPlanVisitor>
public boolean isBlocking()
PhysicalOperator
isBlocking
in class PhysicalOperator
public Result getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
public boolean supportsMultipleInputs()
Operator
supportsMultipleInputs
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleOutputs()
Operator
supportsMultipleOutputs
in class Operator<PhyPlanVisitor>
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class PhysicalOperator
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public void reset()
PhysicalOperator
reset
in class PhysicalOperator
public List<PhysicalPlan> getSortPlans()
public void setSortPlans(List<PhysicalPlan> sortPlans)
public POUserComparisonFunc getMSortFunc()
public void setMSortFunc(POUserComparisonFunc sortFunc)
public Comparator<Tuple> getMComparator()
public void setLimit(long l)
public long getLimit()
public boolean isLimited()
public POSort clone() throws CloneNotSupportedException
PhysicalOperator
public Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorCopyright © 2007-2017 The Apache Software Foundation