public static class GenericUDAFPercentRank.GenericUDAFPercentRankEvaluator extends GenericUDAFRank.GenericUDAFAbstractRankEvaluator
GenericUDAFEvaluator.AbstractAggregationBuffer, GenericUDAFEvaluator.AggregationBuffer, GenericUDAFEvaluator.AggregationType, GenericUDAFEvaluator.Mode
Constructor and Description |
---|
GenericUDAFPercentRank.GenericUDAFPercentRankEvaluator() |
Modifier and Type | Method and Description |
---|---|
ObjectInspector |
init(GenericUDAFEvaluator.Mode m,
ObjectInspector[] parameters)
Initialize the evaluator.
|
Object |
terminate(GenericUDAFEvaluator.AggregationBuffer agg)
Get final aggregation result.
|
getNewAggregationBuffer, isStreaming, iterate, merge, nextRank, reset, terminatePartial
aggregate, close, configure, evaluate, getWindowingEvaluator, isEstimable
public GenericUDAFPercentRank.GenericUDAFPercentRankEvaluator()
public ObjectInspector init(GenericUDAFEvaluator.Mode m, ObjectInspector[] parameters) throws HiveException
GenericUDAFEvaluator
init
in class GenericUDAFRank.GenericUDAFAbstractRankEvaluator
m
- The mode of aggregation.parameters
- The ObjectInspector for the parameters: In PARTIAL1 and COMPLETE
mode, the parameters are original data; In PARTIAL2 and FINAL
mode, the parameters are just partial aggregations (in that case,
the array will always have a single element).HiveException
public Object terminate(GenericUDAFEvaluator.AggregationBuffer agg) throws HiveException
GenericUDAFEvaluator
terminate
in class GenericUDAFRank.GenericUDAFAbstractRankEvaluator
HiveException
Copyright © 2017 The Apache Software Foundation. All rights reserved.