public class POSimpleTezLoad extends POLoad implements TezInput
PhysicalOperator.OriginalLocation
alias, illustrator, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POSimpleTezLoad(OperatorKey k,
FileSpec lfile) |
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()
Previously, we reused the same Result object for all results, but we found
certain operators (e.g.
|
java.lang.String[] |
getTezInputs() |
void |
replaceInput(java.lang.String oldInputKey,
java.lang.String newInputKey) |
void |
setInputKey(java.lang.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, 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 POSimpleTezLoad(OperatorKey k, FileSpec lfile)
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 POLoad
ExecException
public void setInputKey(java.lang.String inputKey)
Copyright © 2007-2012 The Apache Software Foundation