public interface AggsHandleFunction extends AggsHandleFunctionBase
It is code generated to handle all
AggregateFunctions together in an aggregation.
It is the entry point for aggregate operators to operate all
|Modifier and Type||Method and Description|
Gets the result of the aggregation from the current accumulators.
Set window size for the aggregate function.
accumulate, cleanup, close, createAccumulators, getAccumulators, merge, open, resetAccumulators, retract, setAccumulators
RowData getValue() throws Exception
void setWindowSize(int windowSize)
We may need to set the value for some window functions may require the total rows of
current window frame to do calculation. For example, the function PERCENT_RANK need to know
the window's size, and the SQL looks like:
SELECT PERCENT_RANK() OVER ([ partition_by_clause] order_by_clause).
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.