@InterfaceAudience.Private @InterfaceStability.Evolving public class POBuildBloomRearrangeTez extends POLocalRearrangeTez
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_BLOOM_HASH_TYPE |
static String |
DEFAULT_BLOOM_STRATEGY |
static int |
DEFAULT_BLOOM_VECTOR_SIZE_BYTES |
static int |
DEFAULT_NUM_BLOOM_FILTERS_REDUCE |
static int |
DEFAULT_NUM_BLOOM_HASH_FUNCTIONS |
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 |
---|
POBuildBloomRearrangeTez(POLocalRearrangeTez lr,
boolean createBloomInMap,
int numBloomFilters,
int vectorSizeBytes,
int numHash,
int hashType) |
Modifier and Type | Method and Description |
---|---|
void |
attachOutputs(Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs,
org.apache.hadoop.conf.Configuration conf) |
POBuildBloomRearrangeTez |
clone()
Make a deep copy of this operator.
|
boolean |
containsOutputKey(String key) |
Result |
getNextTuple()
Calls getNext on the generate operator inside the nested
physical plan.
|
static int |
getNumBloomFilters(org.apache.hadoop.conf.Configuration conf) |
String[] |
getTezOutputs() |
String |
name() |
void |
replaceOutput(String oldOutputKey,
String newOutputKey) |
void |
setBloomOutputKey(String bloomOutputKey) |
void |
setSkipNullKeys(boolean skipNullKeys) |
getRearrangedTuple, isConnectedToPackage, isSkewedJoin, 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 static final String DEFAULT_BLOOM_STRATEGY
public static final int DEFAULT_NUM_BLOOM_FILTERS_REDUCE
public static final int DEFAULT_NUM_BLOOM_HASH_FUNCTIONS
public static final String DEFAULT_BLOOM_HASH_TYPE
public static final int DEFAULT_BLOOM_VECTOR_SIZE_BYTES
public POBuildBloomRearrangeTez(POLocalRearrangeTez lr, boolean createBloomInMap, int numBloomFilters, int vectorSizeBytes, int numHash, int hashType)
public static int getNumBloomFilters(org.apache.hadoop.conf.Configuration conf)
public void setSkipNullKeys(boolean skipNullKeys)
public void setBloomOutputKey(String bloomOutputKey)
public boolean containsOutputKey(String key)
containsOutputKey
in class POLocalRearrangeTez
public String[] getTezOutputs()
getTezOutputs
in interface TezOutput
getTezOutputs
in class POLocalRearrangeTez
public void replaceOutput(String oldOutputKey, String newOutputKey)
replaceOutput
in interface TezOutput
replaceOutput
in class POLocalRearrangeTez
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 POBuildBloomRearrangeTez clone() throws CloneNotSupportedException
POLocalRearrange
public String name()
name
in class POLocalRearrangeTez
Copyright © 2007-2017 The Apache Software Foundation