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) |