public class PORankTez extends PORank implements TezInput
PhysicalOperator.OriginalLocation
mTupleFactory
alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Modifier and Type | Method and Description |
---|---|
void |
addInputsToSkip(java.util.Set<java.lang.String> inputsToSkip)
Add to the list of inputs to skip download if already available in vertex cache
|
void |
attachInputs(java.util.Map<java.lang.String,LogicalInput> inputs,
org.apache.hadoop.conf.Configuration conf) |
Result |
getNextTuple() |
protected java.lang.Long |
getRankCounterOffset(java.lang.Integer taskId) |
java.lang.String[] |
getTezInputs() |
java.lang.String |
name() |
void |
replaceInput(java.lang.String oldInputKey,
java.lang.String newInputKey) |
void |
setStatsInputKey(java.lang.String statsInputKey) |
void |
setTuplesInputKey(java.lang.String tuplesInputKey) |
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
addRank, getAscendingCols, getOperationID, getRankPlans, illustratorMarkup, setAscendingCols, setOperationID, setRankPlans, supportsMultipleInputs, supportsMultipleOutputs
addOriginalLocation, addOriginalLocation, attachInput, clone, cloneHelper, copyAliasFrom, 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, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
public PORankTez(PORank copy)
public void setTuplesInputKey(java.lang.String tuplesInputKey)
public void setStatsInputKey(java.lang.String statsInputKey)
public java.lang.String[] getTezInputs()
getTezInputs
in interface TezInput
public void replaceInput(java.lang.String oldInputKey, java.lang.String newInputKey)
replaceInput
in interface TezInput
public void addInputsToSkip(java.util.Set<java.lang.String> inputsToSkip)
TezInput
addInputsToSkip
in interface TezInput
public void attachInputs(java.util.Map<java.lang.String,LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf) throws ExecException
attachInputs
in interface TezInput
ExecException
public Result getNextTuple() throws ExecException
getNextTuple
in class PORank
ExecException
protected java.lang.Long getRankCounterOffset(java.lang.Integer taskId)
getRankCounterOffset
in class PORank
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class PORank
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.Copyright © 2007-2012 The Apache Software Foundation