public abstract class AbstractMapJoinOperator<T extends MapJoinDesc> extends CommonJoinOperator<T> implements java.io.Serializable
Operator.OperatorFunc, Operator.ProgressCounter, Operator.State
Modifier and Type | Field and Description |
---|---|
protected RowContainer<java.util.List<java.lang.Object>> |
emptyList |
protected java.util.List<ExprNodeEvaluator>[] |
joinKeys
The expressions for join inputs's join keys.
|
protected java.util.List<ObjectInspector>[] |
joinKeysObjectInspectors
The ObjectInspectors for the join inputs's join keys.
|
protected java.util.List<ObjectInspector>[] |
joinKeysStandardObjectInspectors
The standard ObjectInspectors for the join inputs's join keys.
|
protected byte |
posBigTable |
alias, aliasFilterTags, condn, countAfterReport, dummyObj, dummyObjVectors, filterMaps, filterTags, forwardCache, heartbeatInterval, intermediate, joinFilterObjectInspectors, joinFilters, joinValues, joinValuesObjectInspectors, joinValuesStandardObjectInspectors, LOG, noOuterJoin, NOTSKIPBIGTABLE, nullsafes, numAliases, offsets, order, rowContainerStandardObjectInspectors, skipVectors, spillTableDesc, totalSz
beginTime, childOperators, childOperatorsArray, childOperatorsTag, colExprMap, conf, counterNames, counterNameToEnum, counters, done, fatalErrorCntr, groupKeyObject, id, inputObjInspectors, inputRows, isLogInfoEnabled, numInputRowsCntr, numOutputRowsCntr, operatorId, out, outputObjInspector, outputRows, parentOperators, reporter, state, statsMap, timeTakenCntr, totalTime
Constructor and Description |
---|
AbstractMapJoinOperator() |
AbstractMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop) |
Modifier and Type | Method and Description |
---|---|
protected void |
fatalErrorMessage(java.lang.StringBuilder errMsg,
long counterCode)
Get the fatal error message based on counter's code.
|
OperatorType |
getType()
Return the type of the specific operator among the
types in OperatorType.
|
protected boolean |
hasAnyNulls(java.util.ArrayList<java.lang.Object> key) |
protected boolean |
hasAnyNulls(MapJoinKey key) |
protected boolean |
hasAnyNulls(java.lang.Object[] key) |
protected void |
initializeOp(Configuration hconf)
Operator specific initialization.
|
checkAndGenObject, closeOp, endGroup, getFilteredValue, getFilterTag, getJoinOutputObjectInspector, getName, getNextSize, getOperatorName, getPosToAliasMap, hasFilter, opAllowedAfterMapJoin, opAllowedBeforeMapJoin, reportProgress, setPosToAliasMap, startGroup
acceptLimitPushdown, allInitializedParentsAreClosed, areAllParentsInitialized, assignCounterNameToEnum, augmentPlan, checkFatalErrors, cleanUpInputFileChanged, cleanUpInputFileChangedOp, clone, close, columnNamesRowResolvedCanBeObtained, dump, dump, flush, forward, getAdditionalCounters, getChildOperators, getChildren, getColumnExprMap, getConf, getConfiguration, getCounterNames, getCounterNameToEnum, getCounters, getDone, getExecContext, getGroupKeyObject, getIdentifier, getInputObjInspectors, getNextCntr, getNumChild, getNumParent, getOperatorId, getParentOperators, getSchema, getStats, getWrappedCounterName, incrCounter, initEvaluators, initEvaluators, initEvaluatorsAndReturnStruct, initialize, initialize, initializeChildren, initializeCounters, initializeLocalWork, initOperatorId, isUseBucketizedHiveInputFormat, jobClose, jobCloseOp, logStats, opAllowedBeforeSortMergeJoin, opAllowedConvertMapJoin, passExecContext, preorderMap, process, processGroup, processOp, removeChild, removeChildAndAdoptItsChildren, removeChildren, removeParent, replaceChild, replaceParent, reset, resetId, resetLastEnumUsed, resetStats, setAlias, setChildOperators, setColumnExprMap, setConf, setCounterNames, setCounterNameToEnum, setDone, setExecContext, setGroupKeyObject, setId, setInputObjInspectors, setOperatorId, setOutputCollector, setParentOperators, setReporter, setSchema, setUseBucketizedHiveInputFormat, supportAutomaticSortMergeJoin, supportSkewJoinOptimization, supportUnionRemoveOptimization, toString, toString, updateCounters
protected transient java.util.List<ExprNodeEvaluator>[] joinKeys
protected transient java.util.List<ObjectInspector>[] joinKeysObjectInspectors
protected transient java.util.List<ObjectInspector>[] joinKeysStandardObjectInspectors
protected transient byte posBigTable
protected transient RowContainer<java.util.List<java.lang.Object>> emptyList
public AbstractMapJoinOperator()
public AbstractMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop)
protected void initializeOp(Configuration hconf) throws HiveException
Operator
initializeOp
in class CommonJoinOperator<T extends MapJoinDesc>
HiveException
protected void fatalErrorMessage(java.lang.StringBuilder errMsg, long counterCode)
Operator
fatalErrorMessage
in class Operator<T extends MapJoinDesc>
errMsg
- error message should be appended to this output parameter.counterCode
- input counter code.public OperatorType getType()
Operator
getType
in class Operator<T extends MapJoinDesc>
protected boolean hasAnyNulls(java.util.ArrayList<java.lang.Object> key)
protected boolean hasAnyNulls(java.lang.Object[] key)
protected boolean hasAnyNulls(MapJoinKey key)
Copyright © 2012 The Apache Software Foundation