public static class GenericUDAFDenseRank.GenericUDAFHypotheticalSetDenseRankEvaluator extends GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator
GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator.CompareResult, GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator.HypotheticalSetRankBuffer, GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator.RankAssets
GenericUDAFEvaluator.AbstractAggregationBuffer, GenericUDAFEvaluator.AggregationBuffer, GenericUDAFEvaluator.AggregationType, GenericUDAFEvaluator.Mode
COUNT_FIELD, PARTIAL_RANK_OI, RANK_FIELD
partitionEvaluator
Constructor and Description |
---|
GenericUDAFHypotheticalSetDenseRankEvaluator() |
Modifier and Type | Method and Description |
---|---|
GenericUDAFEvaluator.AggregationBuffer |
getNewAggregationBuffer()
Get a new aggregation object.
|
protected void |
initPartial2AndFinalOI(ObjectInspector[] parameters) |
void |
iterate(GenericUDAFEvaluator.AggregationBuffer agg,
Object[] parameters)
Iterate through original data.
|
void |
merge(GenericUDAFEvaluator.AggregationBuffer agg,
Object partial)
Merge with partial aggregation result.
|
void |
reset(GenericUDAFEvaluator.AggregationBuffer agg)
Reset the aggregation.
|
Object |
terminate(GenericUDAFEvaluator.AggregationBuffer agg)
Get final aggregation result.
|
Object |
terminatePartial(GenericUDAFEvaluator.AggregationBuffer agg)
Get partial aggregation result.
|
compare, init
aggregate, close, configure, createPartitionEvaluator, estimate, evaluate, getExprString, getPartitionWindowingEvaluator, getWindowingEvaluator, isEstimable
public GenericUDAFHypotheticalSetDenseRankEvaluator()
protected void initPartial2AndFinalOI(ObjectInspector[] parameters)
initPartial2AndFinalOI
in class GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator
public GenericUDAFEvaluator.AggregationBuffer getNewAggregationBuffer() throws HiveException
GenericUDAFEvaluator
getNewAggregationBuffer
in class GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator
HiveException
public void reset(GenericUDAFEvaluator.AggregationBuffer agg) throws HiveException
GenericUDAFEvaluator
reset
in class GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator
HiveException
public void iterate(GenericUDAFEvaluator.AggregationBuffer agg, Object[] parameters) throws HiveException
GenericUDAFEvaluator
iterate
in class GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator
parameters
- The objects of parameters.HiveException
public Object terminatePartial(GenericUDAFEvaluator.AggregationBuffer agg) throws HiveException
GenericUDAFEvaluator
terminatePartial
in class GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator
HiveException
public void merge(GenericUDAFEvaluator.AggregationBuffer agg, Object partial) throws HiveException
GenericUDAFEvaluator
merge
in class GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator
partial
- The partial aggregation result.HiveException
public Object terminate(GenericUDAFEvaluator.AggregationBuffer agg) throws HiveException
GenericUDAFEvaluator
terminate
in class GenericUDAFRank.GenericUDAFHypotheticalSetRankEvaluator
HiveException
Copyright © 2022 The Apache Software Foundation. All rights reserved.