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:

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 inherited from class org.apache.hadoop.hive.ql.exec.CommonJoinOperator

noOuterJoin

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

HIVECOUNTERCREATEDFILES, HIVECOUNTERFATAL

Constructor Summary

AbstractMapJoinOperator()

AbstractMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop)

Method Summary

void	closeOp(boolean abort) All done.
org.apache.hadoop.hive.ql.plan.api.OperatorType	getType() Return the type of the specific operator among the types in OperatorType.

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

endGroup, getName, getOperatorName, getPosToAliasMap, opAllowedAfterMapJoin, opAllowedBeforeMapJoin, setPosToAliasMap, startGroup

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMapJoinOperator

public AbstractMapJoinOperator()

AbstractMapJoinOperator

public AbstractMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop)

Method Detail

getType

public org.apache.hadoop.hive.ql.plan.api.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