Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.persistence | |
org.apache.hadoop.hive.ql.optimizer.ppr | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan.ptf | |
org.apache.hadoop.hive.ql.udf.generic |
Standard toolkit and framework for generic User-defined functions.
|
org.apache.hadoop.hive.ql.udf.ptf |
Modifier and Type | Class and Description |
---|---|
class |
ExprNodeColumnEvaluator
This evaluator gets the column from the row object.
|
class |
ExprNodeConstantEvaluator
ExprNodeConstantEvaluator.
|
class |
ExprNodeDynamicValueEvaluator
ExprNodeDynamicEvaluator.
|
class |
ExprNodeEvaluatorHead
Increases version number of each evaluations for correct caching
|
class |
ExprNodeEvaluatorRef
Returns evaluation result of other evaluator
|
class |
ExprNodeFieldEvaluator
This Evaluator can evaluate s.f for s as both struct and list of struct.
|
class |
ExprNodeGenericFuncEvaluator
ExprNodeGenericFuncEvaluator.
|
Modifier and Type | Field and Description |
---|---|
protected ExprNodeEvaluator[] |
ReduceSinkOperator.bucketEval
Evaluators for bucketing columns.
|
protected ExprNodeEvaluator[] |
SelectOperator.eval |
protected ExprNodeEvaluator[] |
ReduceSinkOperator.keyEval
The evaluators for the key columns.
|
protected ExprNodeEvaluator[] |
ReduceSinkOperator.partitionEval
The evaluators for the partition columns (CLUSTER BY or DISTRIBUTE BY in
Hive language).
|
protected ExprNodeEvaluator[] |
ReduceSinkOperator.valueEval
The evaluators for the value columns.
|
Modifier and Type | Field and Description |
---|---|
protected List<ExprNodeEvaluator> |
CommonJoinOperator.residualJoinFilters
List of evaluators for conditions which appear on on-clause and needs to be
evaluated before emitting rows.
|
Modifier and Type | Method and Description |
---|---|
static ExprNodeEvaluator |
ExprNodeEvaluatorFactory.get(ExprNodeDesc desc) |
static ExprNodeEvaluator |
ExprNodeEvaluatorFactory.get(ExprNodeDesc desc,
org.apache.hadoop.conf.Configuration conf) |
ExprNodeEvaluator[] |
ExprNodeEvaluator.getChildren()
Return child evaluators if exist
|
ExprNodeEvaluator[] |
ExprNodeGenericFuncEvaluator.getChildren() |
static ExprNodeEvaluator |
ExprNodeEvaluatorFactory.toCachedEval(ExprNodeEvaluator eval)
Should be called before eval is initialized
|
static ExprNodeEvaluator[] |
ExprNodeEvaluatorFactory.toCachedEvals(ExprNodeEvaluator[] evals) |
Modifier and Type | Method and Description |
---|---|
protected static ObjectInspector[] |
Operator.initEvaluators(ExprNodeEvaluator<?>[] evals,
int start,
int length,
ObjectInspector rowInspector)
Initialize an array of ExprNodeEvaluator from start, for specified length
and return the result ObjectInspectors.
|
protected static ObjectInspector[] |
Operator.initEvaluators(ExprNodeEvaluator<?>[] evals,
ObjectInspector rowInspector)
Initialize an array of ExprNodeEvaluator and return the result
ObjectInspectors.
|
protected static StructObjectInspector |
ReduceSinkOperator.initEvaluatorsAndReturnStruct(ExprNodeEvaluator[] evals,
List<List<Integer>> distinctColIndices,
List<String> outputColNames,
int length,
ObjectInspector rowInspector)
Initializes array of ExprNodeEvaluator.
|
protected static StructObjectInspector |
Operator.initEvaluatorsAndReturnStruct(ExprNodeEvaluator<?>[] evals,
List<String> outputColName,
ObjectInspector rowInspector)
Initialize an array of ExprNodeEvaluator and put the return values into a
StructObjectInspector with integer field names.
|
static ExprNodeEvaluator |
ExprNodeEvaluatorFactory.toCachedEval(ExprNodeEvaluator eval)
Should be called before eval is initialized
|
static ExprNodeEvaluator[] |
ExprNodeEvaluatorFactory.toCachedEvals(ExprNodeEvaluator[] evals) |
Modifier and Type | Method and Description |
---|---|
static ArrayList<Object> |
JoinUtil.computeKeys(Object row,
List<ExprNodeEvaluator> keyFields,
List<ObjectInspector> keyFieldsOI)
Return the key as a standard object.
|
static Object[] |
JoinUtil.computeMapJoinValues(Object row,
List<ExprNodeEvaluator> valueFields,
List<ObjectInspector> valueFieldsOI,
List<ExprNodeEvaluator> filters,
List<ObjectInspector> filtersOI,
int[] filterMap)
Return the value as a standard object.
|
static Object[] |
JoinUtil.computeMapJoinValues(Object row,
List<ExprNodeEvaluator> valueFields,
List<ObjectInspector> valueFieldsOI,
List<ExprNodeEvaluator> filters,
List<ObjectInspector> filtersOI,
int[] filterMap)
Return the value as a standard object.
|
static List<Object> |
JoinUtil.computeValues(Object row,
List<ExprNodeEvaluator> valueFields,
List<ObjectInspector> valueFieldsOI,
boolean hasFilter)
Return the value as a standard object.
|
protected static boolean |
JoinUtil.isFiltered(Object row,
List<ExprNodeEvaluator> filters,
List<ObjectInspector> filtersOIs)
Returns true if the row does not pass through filters.
|
protected static short |
JoinUtil.isFiltered(Object row,
List<ExprNodeEvaluator> filters,
List<ObjectInspector> ois,
int[] filterMap)
Returns true if the row does not pass through filters.
|
Constructor and Description |
---|
ExprNodeEvaluatorHead(ExprNodeEvaluator referencing) |
ExprNodeEvaluatorRef(ExprNodeEvaluator referencing) |
KeyWrapperFactory(ExprNodeEvaluator[] keyFields,
ObjectInspector[] keyObjectInspectors,
ObjectInspector[] currentKeyObjectInspectors) |
Modifier and Type | Method and Description |
---|---|
JoinUtil.JoinResult |
MapJoinTableContainer.ReusableGetAdaptor.setFromRow(Object row,
List<ExprNodeEvaluator> fields,
List<ObjectInspector> ois)
Changes current rows to which adaptor is referring to the rows corresponding to
the key represented by a row object, and fields and ois used to interpret it.
|
Modifier and Type | Method and Description |
---|---|
static ObjectPair<PrimitiveObjectInspector,ExprNodeEvaluator> |
PartExprEvalUtils.prepareExpr(ExprNodeGenericFuncDesc expr,
List<String> partColumnNames,
List<PrimitiveTypeInfo> partColumnTypeInfos) |
Modifier and Type | Method and Description |
---|---|
static Object |
PartExprEvalUtils.evaluateExprOnPart(ObjectPair<PrimitiveObjectInspector,ExprNodeEvaluator> pair,
Object partColValues) |
Modifier and Type | Method and Description |
---|---|
static ExprNodeEvaluator |
WindowingExprNodeEvaluatorFactory.get(LeadLagInfo llInfo,
ExprNodeDesc desc) |
Modifier and Type | Method and Description |
---|---|
ExprNodeEvaluator |
PTFExpressionDef.getExprEvaluator() |
Modifier and Type | Method and Description |
---|---|
void |
PTFExpressionDef.setExprEvaluator(ExprNodeEvaluator exprEvaluator) |
Modifier and Type | Method and Description |
---|---|
ExprNodeEvaluator |
GenericUDFLeadLag.getExprEvaluator() |
Modifier and Type | Method and Description |
---|---|
void |
GenericUDFLeadLag.setExprEvaluator(ExprNodeEvaluator exprEvaluator) |
Constructor and Description |
---|
Symbol(ExprNodeEvaluator symbolExprEval,
ObjectInspector symbolOI) |
Constructor and Description |
---|
SymbolParser(String patternStr,
ArrayList<String> symbolNames,
ArrayList<ExprNodeEvaluator> symbolExprEvals,
ArrayList<ObjectInspector> symbolExprOIs) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.