Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.vector.ptf | |
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 |
---|---|
int |
PTFRollingPartition.rowToProcess(WindowFrameDef wFrameDef)
Gets the next row index that the data within the window are available and can be processed
|
Modifier and Type | Field and Description |
---|---|
protected WindowFrameDef |
VectorPTFEvaluatorBase.windowFrameDef |
Modifier and Type | Method and Description |
---|---|
WindowFrameDef[] |
VectorPTFDesc.getEvaluatorWindowFrameDefs() |
Modifier and Type | Method and Description |
---|---|
static VectorPTFEvaluatorBase |
VectorPTFDesc.getEvaluator(VectorPTFDesc.SupportedFunctionType functionType,
WindowFrameDef windowFrameDef,
org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type columnVectorType,
VectorExpression inputVectorExpression,
int outputColumnNum) |
protected void |
PTFDeserializer.initialize(WindowFrameDef winFrame,
ShapeDetails inpShape) |
void |
VectorPTFDesc.setEvaluatorWindowFrameDefs(WindowFrameDef[] evaluatorWindowFrameDefs) |
Modifier and Type | Method and Description |
---|---|
WindowFrameDef |
WindowFunctionDef.getWindowFrame() |
Modifier and Type | Method and Description |
---|---|
void |
WindowFunctionDef.setWindowFrame(WindowFrameDef windowFrame) |
Modifier and Type | Field and Description |
---|---|
protected WindowFrameDef |
GenericUDAFStreamingEvaluator.wFrameDef |
Modifier and Type | Method and Description |
---|---|
protected BasePartitionEvaluator |
GenericUDAFSum.GenericUDAFSumHiveDecimal.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFSum.GenericUDAFSumDouble.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFSum.GenericUDAFSumLong.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFAverage.GenericUDAFAverageEvaluatorDouble.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI) |
protected BasePartitionEvaluator |
GenericUDAFEvaluator.createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI)
This class needs to be overridden by the child class to implement function
specific evaluator.
|
BasePartitionEvaluator |
GenericUDAFEvaluator.getPartitionWindowingEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI)
When evaluating an aggregates over a fixed Window, streaming is not possible
especially for RANGE Window type.
|
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 WindowFrameDef |
BasePartitionEvaluator.winFrame |
Modifier and Type | Method and Description |
---|---|
protected static BasePartitionEvaluator.Range |
BasePartitionEvaluator.getRange(WindowFrameDef winFrame,
int currRow,
PTFPartition p) |
static ValueBoundaryScanner |
ValueBoundaryScanner.getScanner(WindowFrameDef winFrameDef) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.