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

Packages that use InternalTimeServiceManager

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

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

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

Modifier and Type	Class	Description
class	InternalTimeServiceManagerImpl<K>	An entity keeping all the time-related services.

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

Modifier and Type	Method	Description
<K> InternalTimeServiceManager<K>	InternalTimeServiceManager.Provider.create(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStatedBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)
InternalTimeServiceManager<?>	StreamOperatorStateContext.internalTimerServiceManager()	Returns the internal timer service manager for the stream operator.

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

Modifier and Type	Method	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	Description
OperatorSnapshotFutures	StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.CheckpointedStreamOperator streamOperator, Optional<InternalTimeServiceManager<?>> timeServiceManager, String operatorName, long checkpointId, long timestamp, org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions, org.apache.flink.runtime.state.CheckpointStreamFactory factory, boolean isUsingCustomRawKeyedState)

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

Classes in org.apache.flink.streaming.api.operators.sorted.state that implement InternalTimeServiceManager

Modifier and Type	Class	Description
class	BatchExecutionInternalTimeServiceManager<K>	An implementation of a InternalTimeServiceManager that manages timers with a single active key at a time.

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

Modifier and Type	Method	Description
static <K> InternalTimeServiceManager<K>	BatchExecutionInternalTimeServiceManager.create(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStatedBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)