org.apache.hadoop.hive.ql.exec

Class TezDummyStoreOperator

java.lang.Object

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

org.apache.hadoop.hive.ql.exec.DummyStoreOperator

org.apache.hadoop.hive.ql.exec.TezDummyStoreOperator

All Implemented Interfaces:

Serializable, Cloneable, Node

public class TezDummyStoreOperator
extends DummyStoreOperator

A dummy store operator same as the dummy store operator but for tez. This is required so that we don't check for tez everytime before forwarding a record. In tez records flow down from the dummy store operator in processOp phase unlike in map reduce.

See Also:

Serialized Form

Nested Class Summary

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

Operator.Counter, Operator.OperatorFunc, Operator.State

Field Summary

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

result

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

abortOp, alias, asyncInitOperations, bucketingVersion, cContext, childOperators, childOperatorsArray, childOperatorsTag, conf, CONTEXT_NAME_KEY, done, groupKeyObject, HIVE_COUNTER_CREATED_DYNAMIC_PARTITIONS, HIVE_COUNTER_CREATED_FILES, HIVE_COUNTER_FATAL, id, indexForTezUnion, inputObjInspectors, LOG, numRows, operatorId, out, outputObjInspector, parentOperators, reporter, runTimeNumRows, state, statsMap

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TezDummyStoreOperator() Kryo ctor.
	TezDummyStoreOperator(CompilationOpContext ctx)

Method Summary

Modifier and Type	Method and Description
boolean	getFetchDone()
void	process(Object row, int tag) Unlike the MR counterpoint, on Tez we want processOp to forward the records.
void	setFetchDone(boolean fetchDone)

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

getName, getOperatorName, getResult, getType, initializeOp, reset

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

abort, acceptLimitPushdown, allInitializedParentsAreClosed, areAllParentsInitialized, augmentPlan, cleanUpInputFileChanged, cleanUpInputFileChangedOp, clone, cloneOp, cloneRecursiveChildren, close, closeOp, columnNamesRowResolvedCanBeObtained, completeInitializationOp, createDummy, defaultEndGroup, defaultStartGroup, dump, dump, endGroup, flush, flushRecursive, forward, forward, forward, getAdditionalCounters, getBucketingVersion, getChildOperators, getChildren, getColumnExprMap, getCompilationOpContext, getConf, getConfiguration, getCounterName, getDone, getExecContext, getGroupKeyObject, getIdentifier, getIndexForTezUnion, getInputObjInspectors, getIsReduceSink, getMarker, getNextCntr, getNumChild, getNumParent, getOperatorId, getOpTraits, getOutputObjInspector, getParentOperators, getReduceOutputName, getSchema, getStatistics, getStats, initEvaluators, initEvaluators, initEvaluatorsAndReturnStruct, initialize, initialize, initializeChildren, initializeLocalWork, initOperatorId, isUseBucketizedHiveInputFormat, jobClose, jobCloseOp, logicalEquals, logicalEqualsTree, logStats, opAllowedAfterMapJoin, opAllowedBeforeMapJoin, opAllowedBeforeSortMergeJoin, opAllowedConvertMapJoin, passExecContext, preorderMap, processGroup, removeChild, removeChildAndAdoptItsChildren, removeParent, removeParents, replaceChild, replaceParent, setAlias, setBucketingVersion, setChildOperators, setColumnExprMap, setCompilationOpContext, setConf, setDone, setExecContext, setGroupKeyObject, setIndexForTezUnion, setInputContext, setInputObjInspectors, setMarker, setNextVectorBatchGroupStatus, setOpTraits, setOutputCollector, setParentOperators, setReporter, setSchema, setStatistics, setUseBucketizedHiveInputFormat, startGroup, supportAutomaticSortMergeJoin, supportSkewJoinOptimization, supportUnionRemoveOptimization, toString, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

TezDummyStoreOperator

protected TezDummyStoreOperator()

Kryo ctor.

TezDummyStoreOperator

public TezDummyStoreOperator(CompilationOpContext ctx)

Method Detail

process

public void process(Object row,
                    int tag)
             throws HiveException

Unlike the MR counterpoint, on Tez we want processOp to forward the records.

Overrides:

process in class DummyStoreOperator

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

getFetchDone

public boolean getFetchDone()

setFetchDone

public void setFetchDone(boolean fetchDone)