org.apache.hadoop.hive.ql.exec
Class DemuxOperator
java.lang.Object
org.apache.hadoop.hive.ql.exec.Operator<DemuxDesc>
org.apache.hadoop.hive.ql.exec.DemuxOperator
- All Implemented Interfaces:
- Serializable, Cloneable, Node
public class DemuxOperator
- extends Operator<DemuxDesc>
- implements Serializable
DemuxOperator is an operator used by MapReduce Jobs optimized by
CorrelationOptimizer. If used, DemuxOperator is the first operator in reduce
phase. In the case that multiple operation paths are merged into a single one, it will dispatch
the record to corresponding child operators (Join or GBY).
- See Also:
- Serialized Form
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, opAllowedAfterMapJoin, opAllowedBeforeMapJoin, opAllowedBeforeSortMergeJoin, opAllowedConvertMapJoin, passExecContext, preorderMap, processGroup, 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 |
DemuxOperator
public DemuxOperator()
processOp
public void processOp(Object row,
int tag)
throws HiveException
- Description copied from class:
Operator
- Process the row.
- Specified by:
processOp
in class Operator<DemuxDesc>
- Parameters:
row
- The object representing the row.tag
- The tag of the row usually means which parent this row comes from.
Rows with the same tag should have exactly the same rowInspector
all the time.
- Throws:
HiveException
forward
public void forward(Object row,
ObjectInspector rowInspector)
throws HiveException
- Throws:
HiveException
startGroup
public void startGroup()
throws HiveException
- Overrides:
startGroup
in class Operator<DemuxDesc>
- Throws:
HiveException
endGroup
public void endGroup()
throws HiveException
- Overrides:
endGroup
in class Operator<DemuxDesc>
- 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<DemuxDesc>
- Returns:
- the name of the operator
getOperatorName
public static String getOperatorName()
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<DemuxDesc>
- Returns:
- OperatorType.*
Copyright © 2014 The Apache Software Foundation. All rights reserved.