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

Class TopNRecordsCombiner.Factory

java.lang.Object

org.apache.flink.table.runtime.operators.rank.window.combines.TopNRecordsCombiner.Factory

All Implemented Interfaces:

Serializable, RecordsCombiner.Factory

Enclosing class:

TopNRecordsCombiner

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

Factory to create TopNRecordsCombiner.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Factory(GeneratedRecordComparator genSortKeyComparator, RowDataKeySelector sortKeySelector, TypeSerializer<RowData> recordSerializer, long topN)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

Factory

public Factory(GeneratedRecordComparator genSortKeyComparator,
               RowDataKeySelector sortKeySelector,
               TypeSerializer<RowData> recordSerializer,
               long topN)

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