public class POSimpleTezLoad extends POLoad implements TezInput, TezTaskConfigurable
PhysicalOperator.OriginalLocation
alias, illustrator, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POSimpleTezLoad(OperatorKey k,
LoadFunc loader) |
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()
Previously, we reused the same Result object for all results, but we found
certain operators (e.g.
|
String[] |
getTezInputs() |
void |
initialize(org.apache.tez.runtime.api.ProcessorContext processorContext) |
void |
replaceInput(String oldInputKey,
String newInputKey) |
void |
setInputKey(String inputKey) |
getCacheFiles, getLFile, getLimit, getLoadFunc, getPc, getShipFiles, getSignature, illustratorMarkup, isTmpLoad, name, setCacheFiles, setIsTmpLoad, setLFile, setLimit, setPc, setShipFiles, setSignature, setUp, supportsMultipleInputs, supportsMultipleOutputs, tearDown, visit
addOriginalLocation, addOriginalLocation, attachInput, clone, 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 POSimpleTezLoad(OperatorKey k, LoadFunc loader)
public String[] getTezInputs()
getTezInputs
in interface TezInput
public void replaceInput(String oldInputKey, String newInputKey)
replaceInput
in interface TezInput
public void initialize(org.apache.tez.runtime.api.ProcessorContext processorContext) throws ExecException
initialize
in interface TezTaskConfigurable
ExecException
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 POLoad
ExecException
public void setInputKey(String inputKey)
Copyright © 2007-2017 The Apache Software Foundation