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

Packages that use InternalTimeServiceManager

Package	Description
org.apache.flink.state.api.input.operator
org.apache.flink.streaming.api.operators

Uses of InternalTimeServiceManager in org.apache.flink.state.api.input.operator

Methods in org.apache.flink.state.api.input.operator with parameters of type InternalTimeServiceManager

Modifier and Type	Method and Description
void	StateReaderOperator.setup(ExecutionConfig executionConfig, KeyedStateBackend<KEY> keyKeyedStateBackend, InternalTimeServiceManager<KEY> timerServiceManager, SavepointRuntimeContext ctx)

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

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, ProcessingTimeService processingTimeService, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates)

Methods in org.apache.flink.streaming.api.operators that return types with arguments of type InternalTimeServiceManager

Modifier and Type	Method and Description
protected Optional<InternalTimeServiceManager<?>>	AbstractStreamOperator.getTimeServiceManager()
protected Optional<InternalTimeServiceManager<?>>	AbstractStreamOperatorV2.getTimeServiceManager()

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

Modifier and Type	Method and Description
OperatorSnapshotFutures	StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.CheckpointedStreamOperator streamOperator, Optional<InternalTimeServiceManager<?>> timeServiceManager, String operatorName, long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory factory)

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.