org.apache.flink.table.runtime.generated

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

Modifier and Type	Method and Description
BaseRow	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

BaseRow 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