public abstract class VectorReduceSinkCommonOperator extends TerminalOperator<ReduceSinkDesc> implements VectorizationContextRegion
Operator.OperatorFunc, Operator.State
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 |
VectorReduceSinkCommonOperator()
Kryo ctor.
|
|
VectorReduceSinkCommonOperator(CompilationOpContext ctx) |
|
VectorReduceSinkCommonOperator(CompilationOpContext ctx,
VectorizationContext vContext,
OperatorDesc conf) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeOp(boolean abort)
Operator specific close routine.
|
protected void |
collect(org.apache.hadoop.io.BytesWritable keyWritable,
org.apache.hadoop.io.Writable valueWritable) |
boolean |
getIsReduceSink() |
String |
getName()
Gets the name of the node.
|
static String |
getOperatorName() |
VectorizationContext |
getOuputVectorizationContext() |
String |
getReduceOutputName() |
OperatorType |
getType()
Return the type of the specific operator among the
types in OperatorType.
|
protected void |
initializeOp(org.apache.hadoop.conf.Configuration hconf)
Operator specific initialization.
|
void |
setOutputCollector(org.apache.hadoop.mapred.OutputCollector _out) |
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, process, 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 VectorReduceSinkDesc vectorDesc
protected VectorReduceSinkInfo vectorReduceSinkInfo
protected VectorizationContext vContext
protected int[] reduceSinkKeyColumnMap
protected TypeInfo[] reduceSinkKeyTypeInfos
protected VectorExpression[] reduceSinkKeyExpressions
protected int[] reduceSinkValueColumnMap
protected TypeInfo[] reduceSinkValueTypeInfos
protected VectorExpression[] reduceSinkValueExpressions
protected transient boolean reduceSkipTag
protected transient byte reduceTagByte
protected transient BinarySortableSerializeWrite keyBinarySortableSerializeWrite
protected transient LazyBinarySerializeWrite valueLazyBinarySerializeWrite
protected transient VectorSerializeRow<LazyBinarySerializeWrite> valueVectorSerializeRow
protected transient ByteStream.Output valueOutput
protected transient HiveKey keyWritable
protected transient org.apache.hadoop.io.BytesWritable valueBytesWritable
protected transient String taskName
protected transient long batchCounter
protected VectorReduceSinkCommonOperator()
public VectorReduceSinkCommonOperator(CompilationOpContext ctx)
public VectorReduceSinkCommonOperator(CompilationOpContext ctx, VectorizationContext vContext, OperatorDesc conf) throws HiveException
HiveException
protected void initializeOp(org.apache.hadoop.conf.Configuration hconf) throws HiveException
Operator
initializeOp
in class Operator<ReduceSinkDesc>
HiveException
protected void collect(org.apache.hadoop.io.BytesWritable keyWritable, org.apache.hadoop.io.Writable valueWritable) throws IOException
IOException
protected void closeOp(boolean abort) throws HiveException
Operator
closeOp
in class Operator<ReduceSinkDesc>
HiveException
public String getName()
Node
getName
in interface Node
getName
in class TerminalOperator<ReduceSinkDesc>
public static String getOperatorName()
public OperatorType getType()
Operator
getType
in class Operator<ReduceSinkDesc>
public VectorizationContext getOuputVectorizationContext()
getOuputVectorizationContext
in interface VectorizationContextRegion
public boolean getIsReduceSink()
getIsReduceSink
in class Operator<ReduceSinkDesc>
public String getReduceOutputName()
getReduceOutputName
in class Operator<ReduceSinkDesc>
public void setOutputCollector(org.apache.hadoop.mapred.OutputCollector _out)
setOutputCollector
in class Operator<ReduceSinkDesc>
Copyright © 2021 The Apache Software Foundation. All rights reserved.