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

Class AggCombiner.Factory

java.lang.Object

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

All Implemented Interfaces:

Serializable, RecordsCombiner.Factory

Enclosing class:

AggCombiner

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

Factory to create AggCombiner.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
Factory(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler)

Method Summary

Modifier and Type	Method	Description
RecordsCombiner	createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<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> genAggsHandler)

Method Detail

createRecordsCombiner

public RecordsCombiner createRecordsCombiner(RuntimeContext runtimeContext,
                                             WindowTimerService<Long> timerService,
                                             KeyedStateBackend<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