@InterfaceAudience.Private public class POIdentityInOutTez extends POLocalRearrangeTez implements TezInput, TezOutput
PhysicalOperator.OriginalLocation
connectedToPackage, isSkewedJoin, outputKey, writer
index, inp, isCross, keyType, leafOps, mainKeyType, mFakeTuple, mIsDistinct, plans, secondaryKeyType, secondaryLeafOps, secondaryPlans
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POIdentityInOutTez(OperatorKey k,
POLocalRearrange inputRearrange,
String inputKey) |
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.
|
void |
attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs,
org.apache.hadoop.conf.Configuration conf) |
Result |
getNextTuple()
Calls getNext on the generate operator inside the nested
physical plan.
|
String[] |
getTezInputs() |
String |
name() |
void |
replaceInput(String oldInputKey,
String newInputKey) |
void |
setInputKey(String inputKey) |
clone, containsOutputKey, getRearrangedTuple, getTezOutputs, isConnectedToPackage, isSkewedJoin, replaceOutput, setConnectedToPackage, setOutputKey, setSkewedJoin
attachInput, constructLROutput, getIndex, getKeyFromResult, getKeyType, getMainKeyType, getPlans, getProjectedColsMap, getSecondaryProjectedColsMap, illustratorMarkup, isCross, isDistinct, isKeyCompound, isKeyTuple, isProjectStar, isSecondaryKeyTuple, isSecondaryProjectStar, setCross, setDistinct, setIndex, setKeyType, setMultiQueryIndex, setPlans, setPlansFromCombiner, setSecondaryPlans, setStripKeyFromValue, setUseSecondaryKey, supportsMultipleInputs, supportsMultipleOutputs, visit
addOriginalLocation, addOriginalLocation, 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
finalize, getClass, notify, notifyAll, wait, wait, wait
getTezOutputs, replaceOutput
public POIdentityInOutTez(OperatorKey k, POLocalRearrange inputRearrange, String inputKey)
public void setInputKey(String inputKey)
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 void attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf) throws ExecException
attachOutputs
in interface TezOutput
attachOutputs
in class POLocalRearrangeTez
ExecException
public Result getNextTuple() throws ExecException
POLocalRearrange
getNextTuple
in class POLocalRearrangeTez
ExecException
public String name()
name
in class POLocalRearrangeTez
Copyright © 2007-2017 The Apache Software Foundation