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:

Serializable, Cloneable, Node

Direct Known Subclasses:

CommonMergeJoinOperator, MapJoinOperator, SMBMapJoinOperator

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

See Also:

Serialized Form

Nested Class Summary

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

Operator.OperatorFunc, Operator.State

Field Summary

Fields

Modifier and Type	Field and Description
protected RowContainer<List<Object>>	emptyList
protected List<ExprNodeEvaluator>[]	joinKeys The expressions for join inputs's join keys.
protected List<ObjectInspector>[]	joinKeysObjectInspectors The 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, hconf, 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

childOperators, childOperatorsArray, childOperatorsTag, colExprMap, conf, CONTEXT_NAME_KEY, done, groupKeyObject, HIVECOUNTERCREATEDFILES, HIVECOUNTERFATAL, id, inputObjInspectors, isLogDebugEnabled, isLogInfoEnabled, isLogTraceEnabled, operatorId, out, outputObjInspector, parentOperators, PLOG, reporter, state, statsMap

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	closeOp(boolean abort) All done.
OperatorType	getType() Return the type of the specific operator among the types in OperatorType.
protected List<ObjectInspector>	getValueObjectInspectors(byte alias, List<ObjectInspector>[] aliasToObjectInspectors)
protected Collection<Future<?>>	initializeOp(org.apache.hadoop.conf.Configuration hconf) Operator specific initialization.

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

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

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

acceptLimitPushdown, allInitializedParentsAreClosed, areAllParentsInitialized, augmentPlan, cleanUpInputFileChanged, cleanUpInputFileChangedOp, clone, cloneOp, cloneRecursiveChildren, close, columnNamesRowResolvedCanBeObtained, completeInitializationOp, createDummy, defaultEndGroup, defaultStartGroup, dump, dump, flush, forward, getAdditionalCounters, getChildOperators, getChildren, getColumnExprMap, getConf, getConfiguration, getDone, getExecContext, getGroupKeyObject, getIdentifier, getInputObjInspectors, getNextCntr, getNumChild, getNumParent, getOperatorId, getOpTraits, getOutputObjInspector, getParentOperators, getSchema, getStatistics, getStats, initEvaluators, initEvaluators, initEvaluatorsAndReturnStruct, initialize, initialize, initializeChildren, initializeLocalWork, initOperatorId, isUseBucketizedHiveInputFormat, jobClose, jobCloseOp, logStats, opAllowedBeforeSortMergeJoin, opAllowedConvertMapJoin, passExecContext, preorderMap, process, processGroup, removeChild, removeChildAndAdoptItsChildren, removeChildren, removeParent, replaceChild, replaceParent, reset, resetId, resetStats, setAlias, setChildOperators, setColumnExprMap, setConf, setDone, setExecContext, setGroupKeyObject, setId, setInputContext, setInputObjInspectors, setOperatorId, setOpTraits, setOutputCollector, setParentOperators, setReporter, setSchema, setStatistics, setUseBucketizedHiveInputFormat, supportAutomaticSortMergeJoin, supportSkewJoinOptimization, supportUnionRemoveOptimization, toString, toString

Methods inherited from class java.lang.Object

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

Field Detail

joinKeys

protected transient List<ExprNodeEvaluator>[] joinKeys

The expressions for join inputs's join keys.

joinKeysObjectInspectors

protected transient List<ObjectInspector>[] joinKeysObjectInspectors

The ObjectInspectors for the join inputs's join keys.

posBigTable

protected transient byte posBigTable

emptyList

protected transient RowContainer<List<Object>> emptyList

Constructor Detail

AbstractMapJoinOperator

public AbstractMapJoinOperator()

AbstractMapJoinOperator

public AbstractMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop)

Method Detail

initializeOp

protected Collection<Future<?>> initializeOp(org.apache.hadoop.conf.Configuration hconf)
                                      throws HiveException

Description copied from class: Operator

Operator specific initialization.

Overrides:

initializeOp in class CommonJoinOperator<T extends MapJoinDesc>

Throws:

HiveException

getValueObjectInspectors

protected List<ObjectInspector> getValueObjectInspectors(byte alias,
                                             List<ObjectInspector>[] aliasToObjectInspectors)

Overrides:

getValueObjectInspectors in class CommonJoinOperator<T extends MapJoinDesc>

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.*

closeOp

public void closeOp(boolean abort)
             throws HiveException

Description copied from class: CommonJoinOperator

All done.

Overrides:

closeOp in class CommonJoinOperator<T extends MapJoinDesc>

Throws:

HiveException