Uses of Interface
org.apache.flink.streaming.api.operators.InternalTimerService

Packages that use InternalTimerService

Package	Description
org.apache.flink.streaming.api
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.

Uses of InternalTimerService in org.apache.flink.streaming.api

Constructors in org.apache.flink.streaming.api with parameters of type InternalTimerService

Constructor and Description
SimpleTimerService(InternalTimerService<VoidNamespace> internalTimerService)

Uses of InternalTimerService in org.apache.flink.streaming.api.operators

Classes in org.apache.flink.streaming.api.operators that implement InternalTimerService

Modifier and Type	Class and Description
class	InternalTimerServiceImpl<K,N> InternalTimerService that stores timers on the Java heap.

Methods in org.apache.flink.streaming.api.operators that return InternalTimerService

Modifier and Type	Method and Description
<N> InternalTimerService<N>	InternalTimeServiceManager.getInternalTimerService(String name, TimerSerializer<K,N> timerSerializer, Triggerable<K,N> triggerable)
<K,N> InternalTimerService<N>	AbstractStreamOperator.getInternalTimerService(String name, TypeSerializer<N> namespaceSerializer, Triggerable<K,N> triggerable) Returns a InternalTimerService that can be used to query current processing time and event time and to set timers.

Uses of InternalTimerService in org.apache.flink.streaming.runtime.operators.windowing

Fields in org.apache.flink.streaming.runtime.operators.windowing declared as InternalTimerService

Modifier and Type	Field and Description
protected InternalTimerService<W>	WindowOperator.internalTimerService