public static class GenericUDAFRank.GenericUDAFRankEvaluator extends GenericUDAFRank.GenericUDAFAbstractRankEvaluator implements ISupportStreamingModeForWindowing
GenericUDAFEvaluator.AbstractAggregationBuffer, GenericUDAFEvaluator.AggregationBuffer, GenericUDAFEvaluator.AggregationType, GenericUDAFEvaluator.Mode
partitionEvaluator
NULL_RESULT
Constructor and Description |
---|
GenericUDAFRankEvaluator() |
Modifier and Type | Method and Description |
---|---|
Object |
getNextResult(GenericUDAFEvaluator.AggregationBuffer agg) |
int |
getRowsRemainingAfterTerminate() |
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.
|
getNewAggregationBuffer, init, isStreaming, iterate, merge, nextRank, reset, terminate, terminatePartial
aggregate, close, configure, createPartitionEvaluator, estimate, evaluate, getExprString, getPartitionWindowingEvaluator, isEstimable
public Object getNextResult(GenericUDAFEvaluator.AggregationBuffer agg) throws HiveException
getNextResult
in interface ISupportStreamingModeForWindowing
HiveException
public GenericUDAFEvaluator getWindowingEvaluator(WindowFrameDef wFrmDef)
GenericUDAFEvaluator
This method is called after this Evaluator is initialized. The returned Function must be initialized. It is passed the 'window' of aggregation for each row.
getWindowingEvaluator
in class GenericUDAFEvaluator
wFrmDef
- the Window definition in play for this evaluation.public int getRowsRemainingAfterTerminate() throws HiveException
getRowsRemainingAfterTerminate
in interface ISupportStreamingModeForWindowing
HiveException
Copyright © 2022 The Apache Software Foundation. All rights reserved.