public class POSampleSortSpark extends POSort
POSort.SortComparator, POSort.UDFSortComparator
PhysicalOperator.OriginalLocation
isUDFComparatorUsed
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POSampleSortSpark(POSort sort) |
Modifier and Type | Method and Description |
---|---|
Tuple |
illustratorMarkup(Object in,
Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
String |
name() |
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.
|
clone, getLimit, getMAscCols, getMComparator, getMSortFunc, getNextTuple, getSortPlans, isBlocking, isLimited, reset, setLimit, setMSortFunc, setSortPlans
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 POSampleSortSpark(POSort sort)
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class POSort
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public boolean supportsMultipleInputs()
Operator
supportsMultipleInputs
in class POSort
public boolean supportsMultipleOutputs()
Operator
supportsMultipleOutputs
in class POSort
public Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
Illustrable
illustratorMarkup
in interface Illustrable
illustratorMarkup
in class POSort
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorCopyright © 2007-2017 The Apache Software Foundation