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

Packages that use WindowTimerService

Package	Description
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.combines
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
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.join.window.utils
org.apache.flink.table.runtime.operators.rank.window.combines
org.apache.flink.table.runtime.operators.window.async.tvf.combines
org.apache.flink.table.runtime.operators.window.tvf.combines
org.apache.flink.table.runtime.operators.window.tvf.common
org.apache.flink.table.runtime.operators.window.tvf.slicing
org.apache.flink.table.runtime.operators.window.tvf.unslicing

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

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

Modifier and Type	Method	Description
AsyncStateWindowBuffer	AsyncStateRecordsWindowBuffer.Factory.create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, AsyncStateKeyContext keyContext, WindowAsyncState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)
AsyncStateWindowBuffer	AsyncStateWindowBuffer.Factory.create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, AsyncStateKeyContext keyContext, WindowAsyncState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)	Creates a WindowBuffer that buffers elements in memory before flushing.

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

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

Modifier and Type	Method	Description
AsyncStateRecordsCombiner	AsyncStateAggCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, WindowAsyncState<Long> windowState, boolean isEventTime)

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

Constructor	Description
AsyncStateAggCombiner(WindowTimerService<Long> timerService, WindowAsyncValueState<Long> accState, NamespaceAggsHandleFunction<Long> aggregator, boolean isEventTime)

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

Methods in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors that return WindowTimerService

Modifier and Type	Method	Description
protected WindowTimerService<Long>	AbstractAsyncStateSliceWindowAggProcessor.getWindowTimerService()

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	Description
WindowBuffer	RecordsWindowBuffer.Factory.create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)
WindowBuffer	WindowBuffer.Factory.create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)	Creates a WindowBuffer that buffers elements in memory before flushing.

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	Description
RecordsCombiner	AggCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)
RecordsCombiner	GlobalAggCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

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

Constructor	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	Description
protected WindowTimerService<W>	WindowAggProcessorBase.windowTimerService

Methods in org.apache.flink.table.runtime.operators.aggregate.window.processors that return WindowTimerService

Modifier and Type	Method	Description
protected WindowTimerService<Long>	AbstractSliceSyncStateWindowAggProcessor.getWindowTimerService()
protected WindowTimerService<TimeWindow>	UnsliceSyncStateWindowAggProcessor.getWindowTimerService()
protected abstract WindowTimerService<W>	WindowAggProcessorBase.getWindowTimerService()

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	Description
RecordsCombiner	RowTimeDeduplicateRecordsCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

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

Constructor	Description
RowTimeDeduplicateRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> dataState, int rowtimeIndex, boolean keepLastRow, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer)

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

Constructors in org.apache.flink.table.runtime.operators.join.window.utils with parameters of type WindowTimerService

Constructor	Description
WindowJoinHelper(RowDataSerializer leftSerializer, RowDataSerializer rightSerializer, ZoneId shiftTimeZone, WindowTimerService<Long> windowTimerService, JoinConditionWithNullFilters joinCondition, org.apache.flink.streaming.api.operators.TimestampedCollector<org.apache.flink.table.data.RowData> collector, FlinkJoinType joinType)

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	Description
RecordsCombiner	TopNRecordsCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

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

Constructor

Description

TopNRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowMapState<Long,List<org.apache.flink.table.data.RowData>> dataState, Comparator<org.apache.flink.table.data.RowData> sortKeyComparator, org.apache.flink.api.java.functions.KeySelector<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> sortKeySelector, long topN, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer, boolean isEventTime)

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

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

Modifier and Type	Method	Description
AsyncStateRecordsCombiner	AsyncStateRecordsCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, WindowAsyncState<Long> windowState, boolean isEventTime)	Creates a AsyncStateRecordsCombiner that can combine buffered data into async states.

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

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

Modifier and Type	Method	Description
RecordsCombiner	RecordsCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.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.tvf.common

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

Modifier and Type	Class	Description
class	WindowTimerServiceBase<W>	A base implement of WindowTimerService.

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

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

Modifier and Type	Class	Description
class	SlicingWindowTimerServiceImpl	A WindowTimerService for slicing window.

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

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

Modifier and Type	Class	Description
class	UnslicingWindowTimerServiceImpl	A WindowTimerService for unslicing window.