public class POFRJoinTez extends POFRJoin implements TezInput
POFRJoin.TupleToMapKey
PhysicalOperator.OriginalLocation
constExps, dumTup, fe, fragment, inputSchemas, isLeftOuterJoin, keySchemas, keyTypes, LRs, nullBag, phyPlanLists, processingPlan, replFiles, replicates, setUp
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POFRJoinTez(POFRJoin copy,
List<String> inputKeys) |
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.
|
POFRJoinTez |
clone()
Make a copy of this operator.
|
List<String> |
getInputKeys() |
String[] |
getTezInputs() |
String |
name() |
void |
replaceInput(String oldInputKey,
String newInputKey) |
protected void |
setUpHashMap()
Builds the HashMaps by reading replicated inputs from broadcast edges
|
getFragment, getJoinPlans, getLRs, getNextTuple, getReplFiles, getValueTuple, illustratorMarkup, isKeyNull, isLeftOuterJoin, setFragment, setReplFiles, supportsMultipleInputs, supportsMultipleOutputs, 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 POFRJoinTez(POFRJoin copy, List<String> inputKeys) throws ExecException
ExecException
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
protected void setUpHashMap() throws ExecException
setUpHashMap
in class POFRJoin
ExecException
public POFRJoinTez clone() throws CloneNotSupportedException
PhysicalOperator
clone
in class POFRJoin
CloneNotSupportedException
Do not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}
Copyright © 2007-2017 The Apache Software Foundation