org.apache.hadoop.hive.ql.exec
Class CommonJoinOperator<T extends JoinDesc>

java.lang.Object
  org.apache.hadoop.hive.ql.exec.Operator<T>
      org.apache.hadoop.hive.ql.exec.CommonJoinOperator<T>

All Implemented Interfaces:

Serializable, Cloneable, Node

Direct Known Subclasses:

AbstractMapJoinOperator, JoinOperator

public abstract class CommonJoinOperator<T extends JoinDesc>
extends Operator<T>
implements Serializable

Join operator implementation.

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

boolean

noOuterJoin

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

HIVECOUNTERCREATEDFILES, HIVECOUNTERFATAL

Constructor Summary

CommonJoinOperator()

CommonJoinOperator(CommonJoinOperator<T> clone)

Method Summary

void	closeOp(boolean abort) All done.
void	endGroup() Forward a record of join results.
String	getName() Implements the getName function for the Node Interface.
static String	getOperatorName()
Map<Integer,Set<String>>	getPosToAliasMap()
boolean	opAllowedAfterMapJoin()
boolean	opAllowedBeforeMapJoin()
void	setPosToAliasMap(Map<Integer,Set<String>> posToAliasMap)
void	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, getType, 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

Field Detail

noOuterJoin

public transient boolean noOuterJoin

Constructor Detail

CommonJoinOperator

public CommonJoinOperator()

CommonJoinOperator

public CommonJoinOperator(CommonJoinOperator<T> clone)

Method Detail

startGroup

public void startGroup()
                throws HiveException

Overrides:

startGroup in class Operator<T extends JoinDesc>

Throws:

HiveException

endGroup

public void endGroup()
              throws HiveException

Forward a record of join results.

Overrides:

endGroup in class Operator<T extends JoinDesc>

Throws:

HiveException

closeOp

public void closeOp(boolean abort)
             throws HiveException

All done.

Throws:

HiveException

getName

public String getName()

Description copied from class: Operator

Implements the getName function for the Node Interface.

Specified by:

getName in interface Node

Overrides:

getName in class Operator<T extends JoinDesc>

Returns:

the name of the operator

getOperatorName

public static String getOperatorName()

getPosToAliasMap

public Map<Integer,Set<String>> getPosToAliasMap()

Returns:

the posToAliasMap

setPosToAliasMap

public void setPosToAliasMap(Map<Integer,Set<String>> posToAliasMap)

Parameters:

posToAliasMap - the posToAliasMap to set

opAllowedBeforeMapJoin

public boolean opAllowedBeforeMapJoin()

Overrides:

opAllowedBeforeMapJoin in class Operator<T extends JoinDesc>

opAllowedAfterMapJoin

public boolean opAllowedAfterMapJoin()

Overrides:

opAllowedAfterMapJoin in class Operator<T extends JoinDesc>