@InterfaceAudience.Private @InterfaceStability.Evolving public class POBloomFilterRearrangeTez extends POLocalRearrangeTez implements TezInput
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 |
---|
POBloomFilterRearrangeTez(POLocalRearrangeTez lr,
int numBloomFilters) |
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.
|
POBloomFilterRearrangeTez |
clone()
Make a deep copy of this operator.
|
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) |
attachOutputs, 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
public POBloomFilterRearrangeTez(POLocalRearrangeTez lr, int numBloomFilters)
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 Result getNextTuple() throws ExecException
POLocalRearrange
getNextTuple
in class POLocalRearrangeTez
ExecException
public POBloomFilterRearrangeTez clone() throws CloneNotSupportedException
POLocalRearrange
public String name()
name
in class POLocalRearrangeTez
Copyright © 2007-2017 The Apache Software Foundation