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 createAggCombiner
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description Factory(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RecordsCombiner
createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)
Creates aRecordsCombiner
that can combine buffered data into states.
-
-
-
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 aRecordsCombiner
that can combine buffered data into states.- Specified by:
createRecordsCombiner
in interfaceRecordsCombiner.Factory
- Parameters:
runtimeContext
- the currentRuntimeContext
timerService
- the service to register event-time and processing-time timersstateBackend
- the state backend to accessing stateswindowState
- 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
-
-