Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.optimizer.index | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan | |
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 | Method and Description |
---|---|
static GenericUDAFEvaluator |
FunctionRegistry.getGenericUDAFEvaluator(String name,
List<ObjectInspector> argumentOIs,
boolean isDistinct,
boolean isAllColumns)
Get the GenericUDAF evaluator for the name and argumentClasses.
|
GenericUDAFEvaluator |
Registry.getGenericUDAFEvaluator(String name,
List<ObjectInspector> argumentOIs,
boolean isWindowing,
boolean isDistinct,
boolean isAllColumns)
Get the GenericUDAF evaluator for the name and argumentClasses.
|
GenericUDAFEvaluator |
Registry.getGenericWindowingEvaluator(String functionName,
List<ObjectInspector> argumentOIs,
boolean isDistinct,
boolean isAllColumns) |
static GenericUDAFEvaluator |
FunctionRegistry.getGenericWindowingEvaluator(String name,
List<ObjectInspector> argumentOIs,
boolean isDistinct,
boolean isAllColumns) |
Modifier and Type | Method and Description |
---|---|
GenericUDAFEvaluator |
RewriteQueryUsingAggregateIndexCtx.getEval() |
Modifier and Type | Method and Description |
---|---|
void |
RewriteQueryUsingAggregateIndexCtx.setEval(GenericUDAFEvaluator eval) |
Modifier and Type | Field and Description |
---|---|
GenericUDAFEvaluator |
SemanticAnalyzer.GenericUDAFInfo.genericUDAFEvaluator |
Modifier and Type | Method and Description |
---|---|
static GenericUDAFEvaluator |
SemanticAnalyzer.getGenericUDAFEvaluator(String aggName,
ArrayList<ExprNodeDesc> aggParameters,
ASTNode aggTree,
boolean isDistinct,
boolean isAllColumns)
Returns the GenericUDAFEvaluator for the aggregation.
|
Modifier and Type | Method and Description |
---|---|
static SemanticAnalyzer.GenericUDAFInfo |
SemanticAnalyzer.getGenericUDAFInfo(GenericUDAFEvaluator evaluator,
GenericUDAFEvaluator.Mode emode,
ArrayList<ExprNodeDesc> aggParameters)
Returns the GenericUDAFInfo struct for the aggregation.
|
Modifier and Type | Method and Description |
---|---|
GenericUDAFEvaluator |
AggregationDesc.getGenericUDAFEvaluator() |
GenericUDAFEvaluator |
AggregationDesc.getGenericUDAFWritableEvaluator() |
Modifier and Type | Method and Description |
---|---|
void |
AggregationDesc.setGenericUDAFEvaluator(GenericUDAFEvaluator genericUDAFEvaluator) |
void |
AggregationDesc.setGenericUDAFWritableEvaluator(GenericUDAFEvaluator genericUDAFWritableEvaluator) |
Constructor and Description |
---|
AggregationDesc(String genericUDAFName,
GenericUDAFEvaluator genericUDAFEvaluator,
ArrayList<ExprNodeDesc> parameters,
boolean distinct,
GenericUDAFEvaluator.Mode mode) |
Modifier and Type | Method and Description |
---|---|
GenericUDAFEvaluator |
WindowFunctionDef.getWFnEval() |
Modifier and Type | Method and Description |
---|---|
void |
WindowFunctionDef.setWFnEval(GenericUDAFEvaluator wFnEval) |
Modifier and Type | Class and Description |
---|---|
static class |
GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<TYPE> |
static class |
GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal |
static class |
GenericUDAFAverage.GenericUDAFAverageEvaluatorDouble |
static class |
GenericUDAFBloomFilter.GenericUDAFBloomFilterEvaluator
GenericUDAFBloomFilterEvaluator - Evaluator class for BloomFilter
|
static class |
GenericUDAFBridge.GenericUDAFBridgeEvaluator
GenericUDAFBridgeEvaluator.
|
static class |
GenericUDAFComputeStats.GenericUDAFBinaryStatsEvaluator
GenericUDAFBinaryStatsEvaluator.
|
static class |
GenericUDAFComputeStats.GenericUDAFBooleanStatsEvaluator
GenericUDAFBooleanStatsEvaluator.
|
static class |
GenericUDAFComputeStats.GenericUDAFDateStatsEvaluator
GenericUDAFDateStatsEvaluator
High/low value will be saved in stats DB as long value representing days since epoch.
|
static class |
GenericUDAFComputeStats.GenericUDAFDecimalStatsEvaluator |
static class |
GenericUDAFComputeStats.GenericUDAFDoubleStatsEvaluator
GenericUDAFDoubleStatsEvaluator.
|
static class |
GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator
GenericUDAFLongStatsEvaluator.
|
static class |
GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator<V,OI extends PrimitiveObjectInspector> |
static class |
GenericUDAFComputeStats.GenericUDAFStringStatsEvaluator
GenericUDAFStringStatsEvaluator.
|
static class |
GenericUDAFContextNGrams.GenericUDAFContextNGramEvaluator
A constant-space heuristic to estimate the top-k contextual n-grams.
|
static class |
GenericUDAFCorrelation.GenericUDAFCorrelationEvaluator
Evaluate the Pearson correlation coefficient using a stable one-pass
algorithm, based on work by Philippe Pébay and Donald Knuth.
|
static class |
GenericUDAFCount.GenericUDAFCountEvaluator
GenericUDAFCountEvaluator.
|
static class |
GenericUDAFCovariance.GenericUDAFCovarianceEvaluator
Evaluate the variance using the algorithm described in
http://en.wikipedia.org/wiki/Algorithms_for_calculating_variance,
presumably by Pébay, Philippe (2008), in "Formulas for Robust,
One-Pass Parallel Computation of Covariances and Arbitrary-Order
Statistical Moments", Technical Report SAND2008-6212,
Sandia National Laboratories,
http://infoserve.sandia.gov/sand_doc/2008/086212.pdf
Incremental:
n :
|
static class |
GenericUDAFCovarianceSample.GenericUDAFCovarianceSampleEvaluator
Compute the sample covariance by extending GenericUDAFCovarianceEvaluator and
overriding the terminate() method of the evaluator.
|
static class |
GenericUDAFCumeDist.GenericUDAFCumeDistEvaluator |
static class |
GenericUDAFDenseRank.GenericUDAFDenseRankEvaluator |
static class |
GenericUDAFEWAHBitmap.GenericUDAFEWAHBitmapEvaluator |
static class |
GenericUDAFFirstValue.GenericUDAFFirstValueEvaluator |
static class |
GenericUDAFHistogramNumeric.GenericUDAFHistogramNumericEvaluator
Construct a histogram using an algorithm described by Ben-Haim and Tom-Tov.
|
static class |
GenericUDAFLag.GenericUDAFLagEvaluator |
static class |
GenericUDAFLastValue.GenericUDAFLastValueEvaluator |
static class |
GenericUDAFLead.GenericUDAFLeadEvaluator |
static class |
GenericUDAFLeadLag.GenericUDAFLeadLagEvaluator |
static class |
GenericUDAFMax.GenericUDAFMaxEvaluator |
static class |
GenericUDAFMin.GenericUDAFMinEvaluator |
class |
GenericUDAFMkCollectionEvaluator |
static class |
GenericUDAFnGrams.GenericUDAFnGramEvaluator
A constant-space heuristic to estimate the top-k n-grams.
|
static class |
GenericUDAFNTile.GenericUDAFNTileEvaluator |
static class |
GenericUDAFPercentileApprox.GenericUDAFMultiplePercentileApproxEvaluator |
static class |
GenericUDAFPercentileApprox.GenericUDAFPercentileApproxEvaluator
Construct a histogram using the algorithm described by Ben-Haim and Tom-Tov, and then
use it to compute an approximate percentile value.
|
static class |
GenericUDAFPercentileApprox.GenericUDAFSinglePercentileApproxEvaluator |
static class |
GenericUDAFPercentRank.GenericUDAFPercentRankEvaluator |
static class |
GenericUDAFRank.GenericUDAFAbstractRankEvaluator |
static class |
GenericUDAFRank.GenericUDAFRankEvaluator |
static class |
GenericUDAFRowNumber.GenericUDAFAbstractRowNumberEvaluator |
static class |
GenericUDAFRowNumber.GenericUDAFRowNumberEvaluator |
static class |
GenericUDAFStd.GenericUDAFStdEvaluator
Compute the standard deviation by extending GenericUDAFVarianceEvaluator
and overriding the terminate() method of the evaluator.
|
static class |
GenericUDAFStdSample.GenericUDAFStdSampleEvaluator
Compute the sample standard deviation by extending
GenericUDAFVarianceEvaluator and overriding the terminate() method of the
evaluator.
|
class |
GenericUDAFStreamingEvaluator<T1> |
static class |
GenericUDAFStreamingEvaluator.SumAvgEnhancer<T1,T2> |
static class |
GenericUDAFSum.GenericUDAFSumDouble
GenericUDAFSumDouble.
|
static class |
GenericUDAFSum.GenericUDAFSumEvaluator<ResultType extends org.apache.hadoop.io.Writable>
The base type for sum operator evaluator
|
static class |
GenericUDAFSum.GenericUDAFSumHiveDecimal
GenericUDAFSumHiveDecimal.
|
static class |
GenericUDAFSum.GenericUDAFSumLong
GenericUDAFSumLong.
|
static class |
GenericUDAFSumEmptyIsZero.SumZeroIfEmpty |
static class |
GenericUDAFVariance.GenericUDAFVarianceEvaluator
Evaluate the variance using the algorithm described by Chan, Golub, and LeVeque in
"Algorithms for computing the sample variance: analysis and recommendations"
The American Statistician, 37 (1983) pp.
|
static class |
GenericUDAFVarianceSample.GenericUDAFVarianceSampleEvaluator
Compute the sample variance by extending GenericUDAFVarianceEvaluator and
overriding the terminate() method of the evaluator.
|
Modifier and Type | Field and Description |
---|---|
protected GenericUDAFEvaluator |
GenericUDAFStreamingEvaluator.wrappedEval |
Modifier and Type | Method and Description |
---|---|
GenericUDAFEvaluator |
GenericUDAFSum.getEvaluator(GenericUDAFParameterInfo info) |
GenericUDAFEvaluator |
GenericUDAFPercentileApprox.getEvaluator(GenericUDAFParameterInfo info) |
GenericUDAFEvaluator |
GenericUDAFCount.getEvaluator(GenericUDAFParameterInfo paramInfo) |
GenericUDAFEvaluator |
GenericUDAFBloomFilter.getEvaluator(GenericUDAFParameterInfo info) |
GenericUDAFEvaluator |
GenericUDAFAverage.getEvaluator(GenericUDAFParameterInfo paramInfo) |
GenericUDAFEvaluator |
GenericUDAFResolver2.getEvaluator(GenericUDAFParameterInfo info)
Get the evaluator for the parameter types.
|
GenericUDAFEvaluator |
GenericUDAFLeadLag.getEvaluator(GenericUDAFParameterInfo parameters) |
GenericUDAFEvaluator |
AbstractGenericUDAFResolver.getEvaluator(GenericUDAFParameterInfo info) |
GenericUDAFEvaluator |
GenericUDAFFirstValue.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFCollectSet.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFHistogramNumeric.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFCovariance.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFCollectList.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFStd.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFContextNGrams.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFComputeStats.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFSum.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFSumEmptyIsZero.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFStdSample.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFMin.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFRowNumber.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFVariance.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFVarianceSample.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFNTile.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFCount.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBloomFilter.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFCorrelation.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFAverage.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBridge.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFEWAHBitmap.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFMax.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFResolver.getEvaluator(TypeInfo[] parameters)
Deprecated.
Get the evaluator for the parameter types.
|
GenericUDAFEvaluator |
GenericUDAFRank.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFCovarianceSample.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
AbstractGenericUDAFResolver.getEvaluator(TypeInfo[] info) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrCount.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrSXX.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrSYY.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrAvgX.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrAvgY.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrSlope.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrR2.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrSXY.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFBinarySetFunctions.RegrIntercept.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFLastValue.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFnGrams.getEvaluator(TypeInfo[] parameters) |
GenericUDAFEvaluator |
GenericUDAFFirstValue.GenericUDAFFirstValueEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef) |
GenericUDAFEvaluator |
GenericUDAFLead.GenericUDAFLeadEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef) |
GenericUDAFEvaluator |
GenericUDAFSum.GenericUDAFSumHiveDecimal.getWindowingEvaluator(WindowFrameDef wFrameDef) |
GenericUDAFEvaluator |
GenericUDAFSum.GenericUDAFSumDouble.getWindowingEvaluator(WindowFrameDef wFrameDef) |
GenericUDAFEvaluator |
GenericUDAFSum.GenericUDAFSumLong.getWindowingEvaluator(WindowFrameDef wFrameDef) |
GenericUDAFEvaluator |
GenericUDAFMin.GenericUDAFMinEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef) |
GenericUDAFEvaluator |
GenericUDAFRowNumber.GenericUDAFRowNumberEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef) |
GenericUDAFEvaluator |
GenericUDAFAverage.GenericUDAFAverageEvaluatorDouble.getWindowingEvaluator(WindowFrameDef wFrameDef) |
GenericUDAFEvaluator |
GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal.getWindowingEvaluator(WindowFrameDef wFrameDef) |
GenericUDAFEvaluator |
GenericUDAFEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef)
When evaluating an aggregates over a fixed Window, the naive way to compute
results is to compute the aggregate for each row.
|
GenericUDAFEvaluator |
GenericUDAFMax.GenericUDAFMaxEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef) |
GenericUDAFEvaluator |
GenericUDAFLag.GenericUDAFLagEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef) |
GenericUDAFEvaluator |
GenericUDAFRank.GenericUDAFRankEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef) |
GenericUDAFEvaluator |
GenericUDAFLastValue.GenericUDAFLastValueEvaluator.getWindowingEvaluator(WindowFrameDef wFrmDef) |
Constructor and Description |
---|
GenericUDAFStreamingEvaluator(GenericUDAFEvaluator wrappedEval,
WindowFrameDef wFrameDef) |
SumAvgEnhancer(GenericUDAFEvaluator wrappedEval,
WindowFrameDef wFrameDef) |
Modifier and Type | Field and Description |
---|---|
protected GenericUDAFEvaluator |
BasePartitionEvaluator.wrappedEvaluator |
Copyright © 2021 The Apache Software Foundation. All rights reserved.