Package org.apache.flink.table.runtime.operators.aggregate.window.combines

Class GlobalAggCombiner.Factory

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.window.combines.GlobalAggCombiner.Factory

All Implemented Interfaces:

Serializable, RecordsCombiner.Factory

Enclosing class:

GlobalAggCombiner

public static final class GlobalAggCombiner.Factory
extends Object
implements RecordsCombiner.Factory

Factory to create GlobalAggCombiner.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
Factory(GeneratedNamespaceAggsHandleFunction<Long> genLocalAggsHandler, GeneratedNamespaceAggsHandleFunction<Long> genGlobalAggsHandler)

Method Summary

Modifier and Type	Method	Description
RecordsCombiner	createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)	Creates a RecordsCombiner that can combine buffered data into states.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Factory

public Factory(GeneratedNamespaceAggsHandleFunction<Long> genLocalAggsHandler,
               GeneratedNamespaceAggsHandleFunction<Long> genGlobalAggsHandler)

Method Detail

createRecordsCombiner

public RecordsCombiner createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext,
                                             WindowTimerService<Long> timerService,
                                             org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend,
                                             WindowState<Long> windowState,
                                             boolean isEventTime)
                                      throws Exception

Description copied from interface: RecordsCombiner.Factory

Creates a RecordsCombiner that can combine buffered data into states.

Specified by:

createRecordsCombiner in interface RecordsCombiner.Factory

Parameters:

runtimeContext - the current RuntimeContext

timerService - the service to register event-time and processing-time timers

stateBackend - the state backend to accessing states

windowState - the window state to flush buffered data into.

isEventTime - indicates whether the operator works in event-time or processing-time mode, used for register corresponding timers.

Throws:

Exception