public class VectorReduceSinkMultiKeyOperator extends VectorReduceSinkUniformHashOperator
Operator.OperatorFunc, Operator.State
serializedKeySeries
batchCounter, keyBinarySortableSerializeWrite, keyWritable, reduceSinkKeyColumnMap, reduceSinkKeyExpressions, reduceSinkKeyTypeInfos, reduceSinkValueColumnMap, reduceSinkValueExpressions, reduceSinkValueTypeInfos, reduceSkipTag, reduceTagByte, taskName, valueBytesWritable, valueLazyBinarySerializeWrite, valueOutput, valueVectorSerializeRow, vContext, vectorDesc, vectorReduceSinkInfo
abortOp, alias, asyncInitOperations, cContext, childOperators, childOperatorsArray, childOperatorsTag, colExprMap, conf, CONTEXT_NAME_KEY, done, groupKeyObject, HIVECOUNTERCREATEDFILES, HIVECOUNTERFATAL, id, indexForTezUnion, inputObjInspectors, isLogDebugEnabled, isLogInfoEnabled, isLogTraceEnabled, operatorId, outputObjInspector, parentOperators, PLOG, reporter, runTimeNumRows, state, statsMap
Modifier | Constructor and Description |
---|---|
protected |
VectorReduceSinkMultiKeyOperator()
Kryo ctor.
|
|
VectorReduceSinkMultiKeyOperator(CompilationOpContext ctx) |
|
VectorReduceSinkMultiKeyOperator(CompilationOpContext ctx,
VectorizationContext vContext,
OperatorDesc conf) |
Modifier and Type | Method and Description |
---|---|
protected void |
initializeOp(org.apache.hadoop.conf.Configuration hconf)
Operator specific initialization.
|
process
closeOp, collect, getIsReduceSink, getName, getOperatorName, getOuputVectorizationContext, getReduceOutputName, getType, setOutputCollector
abort, acceptLimitPushdown, allInitializedParentsAreClosed, areAllParentsInitialized, augmentPlan, cleanUpInputFileChanged, cleanUpInputFileChangedOp, clone, cloneOp, cloneRecursiveChildren, close, columnNamesRowResolvedCanBeObtained, completeInitializationOp, createDummy, defaultEndGroup, defaultStartGroup, dump, dump, endGroup, flush, forward, getAdditionalCounters, getChildOperators, getChildren, getColumnExprMap, getCompilationOpContext, getConf, getConfiguration, getDone, getExecContext, getGroupKeyObject, getIdentifier, getIndexForTezUnion, getInputObjInspectors, getNextCntr, getNumChild, getNumParent, getOperatorId, getOpTraits, getOutputObjInspector, getParentOperators, getSchema, getStatistics, getStats, initEvaluators, initEvaluators, initEvaluatorsAndReturnStruct, initialize, initialize, initializeChildren, initializeLocalWork, initOperatorId, isUseBucketizedHiveInputFormat, jobClose, jobCloseOp, logStats, opAllowedAfterMapJoin, opAllowedBeforeMapJoin, opAllowedBeforeSortMergeJoin, opAllowedConvertMapJoin, passExecContext, preorderMap, processGroup, removeChild, removeChildAndAdoptItsChildren, removeParent, removeParents, replaceChild, replaceParent, reset, resetStats, setAlias, setChildOperators, setColumnExprMap, setCompilationOpContext, setConf, setDone, setExecContext, setGroupKeyObject, setId, setIndexForTezUnion, setInputContext, setInputObjInspectors, setOperatorId, setOpTraits, setParentOperators, setReporter, setSchema, setStatistics, setUseBucketizedHiveInputFormat, startGroup, supportAutomaticSortMergeJoin, supportSkewJoinOptimization, supportUnionRemoveOptimization, toString, toString
protected VectorReduceSinkMultiKeyOperator()
public VectorReduceSinkMultiKeyOperator(CompilationOpContext ctx)
public VectorReduceSinkMultiKeyOperator(CompilationOpContext ctx, VectorizationContext vContext, OperatorDesc conf) throws HiveException
HiveException
protected void initializeOp(org.apache.hadoop.conf.Configuration hconf) throws HiveException
Operator
initializeOp
in class VectorReduceSinkUniformHashOperator
HiveException
Copyright © 2021 The Apache Software Foundation. All rights reserved.