Interface NamespaceAggsHandleFunction<N>
-
- All Superinterfaces:
Function
,NamespaceAggsHandleFunctionBase<N>
,Serializable
public interface NamespaceAggsHandleFunction<N> extends NamespaceAggsHandleFunctionBase<N>
The base class for handling aggregate functions with namespace.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description RowData
getValue(N namespace)
Gets the result of the aggregation from the current accumulators and namespace properties (like window start).-
Methods inherited from interface org.apache.flink.table.runtime.generated.NamespaceAggsHandleFunctionBase
accumulate, cleanup, close, createAccumulators, getAccumulators, merge, open, retract, setAccumulators
-
-
-
-
Method Detail
-
getValue
RowData getValue(N namespace) throws Exception
Gets the result of the aggregation from the current accumulators and namespace properties (like window start).- Parameters:
namespace
- the namespace properties which should be calculated, such window start- Returns:
- the final result (saved in a row) of the current accumulators.
- Throws:
Exception
-
-