Uses of Class
org.apache.flink.streaming.api.operators.InternalTimeServiceManager

Packages that use InternalTimeServiceManager

Package	Description
org.apache.flink.streaming.api.operators

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

Fields in org.apache.flink.streaming.api.operators declared as InternalTimeServiceManager

Modifier and Type	Field and Description
protected InternalTimeServiceManager<?>	AbstractStreamOperator.timeServiceManager

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

Modifier and Type	Method and Description
InternalTimeServiceManager<?>	StreamOperatorStateContext.internalTimerServiceManager() Returns the internal timer service manager for the stream operator.
protected <K> InternalTimeServiceManager<K>	StreamTaskStateInitializerImpl.internalTimeServiceManager(AbstractKeyedStateBackend<K> keyedStatedBackend, KeyContext keyContext, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates)

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

Constructor and Description
InternalTimerServiceSerializationProxy(InternalTimeServiceManager<K> timerServicesManager, ClassLoader userCodeClassLoader, int keyGroupIdx) Constructor to use when restoring timer services.
InternalTimerServiceSerializationProxy(InternalTimeServiceManager<K> timerServicesManager, int keyGroupIdx) Constructor to use when writing timer services.