public class VectorSelectOperator extends Operator<SelectDesc> implements VectorizationContextRegion
Operator.OperatorFunc, Operator.State
Modifier and Type | Field and Description |
---|---|
protected VectorExpression[] |
vExpressions |
abortOp, alias, asyncInitOperations, cContext, childOperators, childOperatorsArray, childOperatorsTag, colExprMap, conf, CONTEXT_NAME_KEY, done, groupKeyObject, HIVECOUNTERCREATEDFILES, HIVECOUNTERFATAL, id, inputObjInspectors, isLogDebugEnabled, isLogInfoEnabled, isLogTraceEnabled, LOG, operatorId, out, outputObjInspector, parentOperators, PLOG, reporter, state, statsMap
Constructor and Description |
---|
VectorSelectOperator()
Kryo ctor.
|
VectorSelectOperator(CompilationOpContext ctx) |
VectorSelectOperator(CompilationOpContext ctx,
VectorizationContext vContext,
OperatorDesc conf) |
Modifier and Type | Method and Description |
---|---|
String |
getName()
Gets the name of the node.
|
static String |
getOperatorName() |
VectorizationContext |
getOuputVectorizationContext() |
OperatorType |
getType()
Return the type of the specific operator among the
types in OperatorType.
|
VectorExpression[] |
getvExpressions() |
VectorExpression[] |
getVExpressions() |
protected void |
initializeOp(org.apache.hadoop.conf.Configuration hconf)
Operator specific initialization.
|
void |
process(Object row,
int tag)
Process the row.
|
void |
setvExpressions(VectorExpression[] vExpressions) |
void |
setVExpressions(VectorExpression[] vExpressions) |
abort, acceptLimitPushdown, allInitializedParentsAreClosed, areAllParentsInitialized, augmentPlan, cleanUpInputFileChanged, cleanUpInputFileChangedOp, clone, cloneOp, cloneRecursiveChildren, close, closeOp, columnNamesRowResolvedCanBeObtained, completeInitializationOp, createDummy, defaultEndGroup, defaultStartGroup, dump, dump, endGroup, flush, forward, getAdditionalCounters, getChildOperators, getChildren, getColumnExprMap, getCompilationOpContext, getConf, getConfiguration, getDone, getExecContext, getGroupKeyObject, getIdentifier, getInputObjInspectors, getIsReduceSink, getNextCntr, getNumChild, getNumParent, getOperatorId, getOpTraits, getOutputObjInspector, getParentOperators, getReduceOutputName, 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, setOutputCollector, setParentOperators, setReporter, setSchema, setStatistics, setUseBucketizedHiveInputFormat, startGroup, supportAutomaticSortMergeJoin, supportSkewJoinOptimization, supportUnionRemoveOptimization, toString, toString
protected VectorExpression[] vExpressions
public VectorSelectOperator(CompilationOpContext ctx, VectorizationContext vContext, OperatorDesc conf) throws HiveException
HiveException
public VectorSelectOperator()
public VectorSelectOperator(CompilationOpContext ctx)
protected void initializeOp(org.apache.hadoop.conf.Configuration hconf) throws HiveException
Operator
initializeOp
in class Operator<SelectDesc>
HiveException
public void process(Object row, int tag) throws HiveException
Operator
process
in class Operator<SelectDesc>
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.HiveException
public VectorExpression[] getvExpressions()
public VectorExpression[] getVExpressions()
public void setvExpressions(VectorExpression[] vExpressions)
public void setVExpressions(VectorExpression[] vExpressions)
public VectorizationContext getOuputVectorizationContext()
getOuputVectorizationContext
in interface VectorizationContextRegion
public OperatorType getType()
Operator
getType
in class Operator<SelectDesc>
public String getName()
Node
getName
in interface Node
getName
in class Operator<SelectDesc>
public static String getOperatorName()
Copyright © 2016 The Apache Software Foundation. All rights reserved.