public class VectorReduceSinkMultiKeyOperator extends VectorReduceSinkCommonOperator
Operator.OperatorFunc, Operator.State
batchCounter, keyBinarySortableSerializeWrite, reduceSinkKeyColumnMap, reduceSinkKeyExpressions, reduceSinkKeyTypeInfos, reduceSinkValueColumnMap, reduceSinkValueExpressions, reduceSinkValueTypeInfos, serializedKeySeries, taskName, vContext, vectorDesc, vectorReduceSinkInfo
abortOp, alias, asyncInitOperations, cContext, childOperators, childOperatorsArray, childOperatorsTag, colExprMap, conf, CONTEXT_NAME_KEY, done, groupKeyObject, HIVECOUNTERCREATEDFILES, HIVECOUNTERFATAL, id, inputObjInspectors, isLogDebugEnabled, isLogInfoEnabled, isLogTraceEnabled, operatorId, outputObjInspector, parentOperators, PLOG, reporter, 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.
|
closeOp, collect, getIsReduceSink, getName, getOperatorName, getOuputVectorizationContext, getReduceOutputName, getType, process, 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, 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, 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 VectorReduceSinkCommonOperator
HiveException
Copyright © 2016 The Apache Software Foundation. All rights reserved.