Uses of Interface
org.apache.flink.table.runtime.operators.window.slicing.WindowTimerService

Packages that use WindowTimerService

Package	Description
org.apache.flink.table.runtime.operators.aggregate.window.buffers
org.apache.flink.table.runtime.operators.aggregate.window.combines
org.apache.flink.table.runtime.operators.aggregate.window.processors
org.apache.flink.table.runtime.operators.deduplicate.window.combines
org.apache.flink.table.runtime.operators.rank.window.combines
org.apache.flink.table.runtime.operators.window.combines
org.apache.flink.table.runtime.operators.window.slicing

Uses of WindowTimerService in org.apache.flink.table.runtime.operators.aggregate.window.buffers

Methods in org.apache.flink.table.runtime.operators.aggregate.window.buffers with parameters of type WindowTimerService

Modifier and Type	Method and Description
WindowBuffer	WindowBuffer.Factory.create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, java.time.ZoneId shiftTimeZone) Creates a WindowBuffer that buffers elements in memory before flushing.
WindowBuffer	RecordsWindowBuffer.Factory.create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, java.time.ZoneId shiftTimeZone)

Uses of WindowTimerService in org.apache.flink.table.runtime.operators.aggregate.window.combines

Methods in org.apache.flink.table.runtime.operators.aggregate.window.combines with parameters of type WindowTimerService

Modifier and Type	Method and Description
RecordsCombiner	AggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)
RecordsCombiner	GlobalAggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

Constructors in org.apache.flink.table.runtime.operators.aggregate.window.combines with parameters of type WindowTimerService

Constructor and Description
AggCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> accState, NamespaceAggsHandleFunction<Long> aggregator, boolean isEventTime)
GlobalAggCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> accState, NamespaceAggsHandleFunction<Long> localAggregator, NamespaceAggsHandleFunction<Long> globalAggregator)

Uses of WindowTimerService in org.apache.flink.table.runtime.operators.aggregate.window.processors

Fields in org.apache.flink.table.runtime.operators.aggregate.window.processors declared as WindowTimerService

Modifier and Type	Field and Description
protected WindowTimerService<Long>	AbstractWindowAggProcessor.windowTimerService

Uses of WindowTimerService in org.apache.flink.table.runtime.operators.deduplicate.window.combines

Methods in org.apache.flink.table.runtime.operators.deduplicate.window.combines with parameters of type WindowTimerService

Modifier and Type	Method and Description
RecordsCombiner	RowTimeDeduplicateRecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

Constructors in org.apache.flink.table.runtime.operators.deduplicate.window.combines with parameters of type WindowTimerService

Constructor and Description
RowTimeDeduplicateRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> dataState, int rowtimeIndex, boolean keepLastRow, TypeSerializer<RowData> recordSerializer)

Uses of WindowTimerService in org.apache.flink.table.runtime.operators.rank.window.combines

Methods in org.apache.flink.table.runtime.operators.rank.window.combines with parameters of type WindowTimerService

Modifier and Type	Method and Description
RecordsCombiner	TopNRecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

Constructors in org.apache.flink.table.runtime.operators.rank.window.combines with parameters of type WindowTimerService

Constructor and Description
TopNRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowMapState<Long,List<RowData>> dataState, Comparator<RowData> sortKeyComparator, KeySelector<RowData,RowData> sortKeySelector, long topN, TypeSerializer<RowData> recordSerializer, boolean isEventTime)

Uses of WindowTimerService in org.apache.flink.table.runtime.operators.window.combines

Methods in org.apache.flink.table.runtime.operators.window.combines with parameters of type WindowTimerService

Modifier and Type	Method and Description
RecordsCombiner	RecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime) Creates a RecordsCombiner that can combine buffered data into states.

Uses of WindowTimerService in org.apache.flink.table.runtime.operators.window.slicing

Classes in org.apache.flink.table.runtime.operators.window.slicing that implement WindowTimerService

Modifier and Type	Class and Description
class	WindowTimerServiceImpl Simple Implements of WindowTimerService.