public interface AggsHandleFunctionBase extends Function
It is code generated to handle all AggregateFunction
s and TableAggregateFunction
s together in an aggregation.
It is the entry point for aggregate operators to operate all AggregateFunction
s and
TableAggregateFunction
s.
Modifier and Type | Method and Description |
---|---|
void |
accumulate(RowData input)
Accumulates the input values to the accumulators.
|
void |
cleanup()
Cleanup for the retired accumulators state.
|
void |
close()
Tear-down method for this function.
|
RowData |
createAccumulators()
Initializes the accumulators and save them to a accumulators row.
|
RowData |
getAccumulators()
Gets the current accumulators (saved in a row) which contains the current aggregated results.
|
void |
merge(RowData accumulators)
Merges the other accumulators into current accumulators.
|
void |
open(StateDataViewStore store)
Initialization method for the function.
|
void |
resetAccumulators()
Resets all the accumulators.
|
void |
retract(RowData input)
Retracts the input values from the accumulators.
|
void |
setAccumulators(RowData accumulators)
Set the current accumulators (saved in a row) which contains the current aggregated results.
|
void open(StateDataViewStore store) throws Exception
Exception
void accumulate(RowData input) throws Exception
input
- input values bundled in a rowException
void retract(RowData input) throws Exception
input
- input values bundled in a rowException
void merge(RowData accumulators) throws Exception
accumulators
- The other row of accumulatorsException
void setAccumulators(RowData accumulators) throws Exception
accumulators
- current accumulatorsException
void resetAccumulators() throws Exception
Exception
RowData getAccumulators() throws Exception
Exception
RowData createAccumulators() throws Exception
Exception
void cleanup() throws Exception
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.