public class VectorReduceSinkLongOperator extends VectorReduceSinkUniformHashOperator
Operator.Counter, Operator.OperatorFunc, Operator.State
serializedKeySeries
batchCounter, isEmptyKey, isEmptyValue, keyBinarySortableSerializeWrite, keyWritable, reducerHash, reduceSinkKeyColumnMap, reduceSinkKeyExpressions, reduceSinkKeyTypeInfos, reduceSinkValueColumnMap, reduceSinkValueExpressions, reduceSinkValueTypeInfos, reduceSkipTag, reduceTagByte, taskName, valueBytesWritable, valueLazyBinarySerializeWrite, valueOutput, valueVectorSerializeRow, vContext, vectorDesc, vectorReduceSinkInfo
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, numRows, operatorId, outputObjInspector, parentOperators, reporter, runTimeNumRows, state, statsMap
Modifier | Constructor and Description |
---|---|
protected |
VectorReduceSinkLongOperator()
Kryo ctor.
|
|
VectorReduceSinkLongOperator(CompilationOpContext ctx) |
|
VectorReduceSinkLongOperator(CompilationOpContext ctx,
OperatorDesc conf,
VectorizationContext vContext,
VectorDesc vectorDesc) |
Modifier and Type | Method and Description |
---|---|
protected void |
initializeOp(org.apache.hadoop.conf.Configuration hconf)
Operator specific initialization.
|
process
closeOp, collect, collect, getInputVectorizationContext, getIsReduceSink, getName, getOperatorName, getOutputVectorizationContext, getReduceOutputName, getType, getVectorDesc, initializeEmptyKey, setOutputCollector
abort, acceptLimitPushdown, allInitializedParentsAreClosed, areAllParentsInitialized, augmentPlan, cleanUpInputFileChanged, cleanUpInputFileChangedOp, clone, cloneOp, cloneRecursiveChildren, close, 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, getMarker, getNextCntr, getNumChild, getNumParent, getOperatorId, getOpTraits, getOutputObjInspector, getParentOperators, 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, reset, setAlias, setBucketingVersion, setChildOperators, setColumnExprMap, setCompilationOpContext, setConf, setDone, setExecContext, setGroupKeyObject, setIndexForTezUnion, setInputContext, setInputObjInspectors, setMarker, setNextVectorBatchGroupStatus, setOpTraits, setParentOperators, setReporter, setSchema, setStatistics, setUseBucketizedHiveInputFormat, startGroup, supportAutomaticSortMergeJoin, supportSkewJoinOptimization, supportUnionRemoveOptimization, toString, toString
protected VectorReduceSinkLongOperator()
public VectorReduceSinkLongOperator(CompilationOpContext ctx)
public VectorReduceSinkLongOperator(CompilationOpContext ctx, OperatorDesc conf, VectorizationContext vContext, VectorDesc vectorDesc) throws HiveException
HiveException
protected void initializeOp(org.apache.hadoop.conf.Configuration hconf) throws HiveException
Operator
initializeOp
in class VectorReduceSinkUniformHashOperator
HiveException
Copyright © 2022 The Apache Software Foundation. All rights reserved.