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

Interface RecordsCombiner.Factory

All Superinterfaces:

Serializable

All Known Implementing Classes:

AggCombiner.Factory, GlobalAggCombiner.Factory, RowTimeDeduplicateRecordsCombiner.Factory, TopNRecordsCombiner.Factory

Enclosing interface:

RecordsCombiner

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface RecordsCombiner.Factory
extends Serializable

A factory that creates a RecordsCombiner.

Method Summary

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

Method Detail

createRecordsCombiner

RecordsCombiner createRecordsCombiner(RuntimeContext runtimeContext,
                                      WindowTimerService<Long> timerService,
                                      KeyedStateBackend<RowData> stateBackend,
                                      WindowState<Long> windowState,
                                      boolean isEventTime)
                               throws Exception

Creates a RecordsCombiner that can combine buffered data into states.

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