public class POMergeJoinTez extends POMergeJoin implements TezInput
POMergeJoin.TuplesToSchemaTupleList
PhysicalOperator.OriginalLocation
rightLoader, rightLoaderFuncSpec
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POMergeJoinTez(POMergeJoin joinOp) |
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,org.apache.tez.runtime.api.LogicalInput> inputs,
org.apache.hadoop.conf.Configuration conf)
Attach the inputs to the operator.
|
POMergeJoinTez |
clone()
Make a copy of this operator.
|
protected LoadFunc |
getRightLoader()
Instantiate right loader
|
java.lang.String[] |
getTezInputs() |
java.lang.String |
name() |
void |
replaceInput(java.lang.String oldInputKey,
java.lang.String newInputKey) |
void |
setInputKey(java.lang.String inputKey) |
getIndexFile, getInnerPlansOf, getJoinType, getLRs, getNextTuple, getSignature, illustratorMarkup, isEndOfInput, setEndOfInput, setIndexFile, setRightInputFileName, setRightLoaderFuncSpec, setSignature, setupRightPipeline, supportsMultipleInputs, supportsMultipleOutputs, throwProcessingException, visit
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 POMergeJoinTez(POMergeJoin joinOp)
public void setInputKey(java.lang.String inputKey)
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,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 java.lang.String name()
name
in class POMergeJoin
protected LoadFunc getRightLoader() throws ExecException
POMergeJoin
getRightLoader
in class POMergeJoin
ExecException
public POMergeJoinTez clone() throws java.lang.CloneNotSupportedException
PhysicalOperator
clone
in class POMergeJoin
java.lang.CloneNotSupportedException
Do not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}
Copyright © 2007-2025 The Apache Software Foundation