public class PORankTez extends PORank implements TezInput
PhysicalOperator.OriginalLocation
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Modifier and Type | Method and Description |
---|---|
void |
addInputsToSkip(Set<String> inputsToSkip)
Add to the list of inputs to skip download if already available in vertex cache
|
void |
attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs,
org.apache.hadoop.conf.Configuration conf)
Attach the inputs to the operator.
|
Result |
getNextTuple() |
protected Long |
getRankCounterOffset(Integer taskId) |
String[] |
getTezInputs() |
String |
name() |
void |
replaceInput(String oldInputKey,
String newInputKey) |
void |
setStatsInputKey(String statsInputKey) |
void |
setTuplesInputKey(String tuplesInputKey) |
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
addRank, clone, getAscendingCols, getOperationID, getRankPlans, illustratorMarkup, setAscendingCols, setOperationID, setRankPlans, supportsMultipleInputs, supportsMultipleOutputs
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, isBlocking, isEndOfAllInput, 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(String tuplesInputKey)
public void setStatsInputKey(String statsInputKey)
public String[] getTezInputs()
getTezInputs
in interface TezInput
public void replaceInput(String oldInputKey, String newInputKey)
replaceInput
in interface TezInput
public void addInputsToSkip(Set<String> inputsToSkip)
TezInput
addInputsToSkip
in interface TezInput
public void attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf) throws ExecException
TezInput
attachInputs
in interface TezInput
inputs
- available inputsconf
- configurationExecException
public Result getNextTuple() throws ExecException
getNextTuple
in class PORank
ExecException
protected Long getRankCounterOffset(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-2017 The Apache Software Foundation