org.apache.flink.table.runtime.generated

Interface NamespaceTableAggsHandleFunction<N>

All Superinterfaces:

Function, NamespaceAggsHandleFunctionBase<N>, Serializable

public interface NamespaceTableAggsHandleFunction<N>
extends NamespaceAggsHandleFunctionBase<N>

The base class for handling table aggregate functions with namespace.

Method Summary

Modifier and Type	Method and Description
void	emitValue(N namespace, RowData key, Collector<RowData> out) Emits 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

emitValue

void emitValue(N namespace,
               RowData key,
               Collector<RowData> out)
        throws Exception

Emits 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

key - the group key for the current emit.

out - the collector used to emit results.

Throws:

Exception