org.apache.hadoop.hive.ql.exec

Class AbstractMapJoinOperator<T extends MapJoinDesc>

java.lang.Object

org.apache.hadoop.hive.ql.exec.Operator<T>

org.apache.hadoop.hive.ql.exec.CommonJoinOperator<T>

org.apache.hadoop.hive.ql.exec.AbstractMapJoinOperator<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, Node

Direct Known Subclasses:

MapJoinOperator, SMBMapJoinOperator

public abstract class AbstractMapJoinOperator<T extends MapJoinDesc>
extends CommonJoinOperator<T>
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.exec.Operator

Operator.OperatorFunc, Operator.ProgressCounter, Operator.State

Field Summary

Fields

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

Fields inherited from class org.apache.hadoop.hive.ql.exec.CommonJoinOperator

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

Fields inherited from class org.apache.hadoop.hive.ql.exec.Operator

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 Summary

Constructors

Constructor and Description
AbstractMapJoinOperator()
AbstractMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop)

Method Summary

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.

Methods inherited from class org.apache.hadoop.hive.ql.exec.CommonJoinOperator

checkAndGenObject, closeOp, endGroup, getFilteredValue, getFilterTag, getJoinOutputObjectInspector, getName, getNextSize, getOperatorName, getPosToAliasMap, hasFilter, opAllowedAfterMapJoin, opAllowedBeforeMapJoin, reportProgress, setPosToAliasMap, startGroup

Methods inherited from class org.apache.hadoop.hive.ql.exec.Operator

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

joinKeys

protected transient java.util.List<ExprNodeEvaluator>[] joinKeys

The expressions for join inputs's join keys.

joinKeysObjectInspectors

protected transient java.util.List<ObjectInspector>[] joinKeysObjectInspectors

The ObjectInspectors for the join inputs's join keys.

joinKeysStandardObjectInspectors

protected transient java.util.List<ObjectInspector>[] joinKeysStandardObjectInspectors

The standard ObjectInspectors for the join inputs's join keys.

posBigTable

protected transient byte posBigTable

emptyList

protected transient RowContainer<java.util.List<java.lang.Object>> emptyList

Constructor Detail

AbstractMapJoinOperator

public AbstractMapJoinOperator()

AbstractMapJoinOperator

public AbstractMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop)

Method Detail

initializeOp

protected void initializeOp(Configuration hconf)
                     throws HiveException

Description copied from class: Operator

Operator specific initialization.

Overrides:

initializeOp in class CommonJoinOperator<T extends MapJoinDesc>

Throws:

HiveException

fatalErrorMessage

protected void fatalErrorMessage(java.lang.StringBuilder errMsg,
                                 long counterCode)

Description copied from class: Operator

Get the fatal error message based on counter's code.

Overrides:

fatalErrorMessage in class Operator<T extends MapJoinDesc>

Parameters:

errMsg - error message should be appended to this output parameter.

counterCode - input counter code.

getType

public OperatorType getType()

Description copied from class: Operator

Return the type of the specific operator among the types in OperatorType.

Specified by:

getType in class Operator<T extends MapJoinDesc>

Returns:

OperatorType.*

hasAnyNulls

protected boolean hasAnyNulls(java.util.ArrayList<java.lang.Object> key)

hasAnyNulls

protected boolean hasAnyNulls(java.lang.Object[] key)

hasAnyNulls

protected boolean hasAnyNulls(MapJoinKey key)