Package | Description |
---|---|
org.apache.flink.streaming.api.operators |
Modifier and Type | Method and Description |
---|---|
static <K> InternalTimeServiceManagerImpl<K> |
InternalTimeServiceManagerImpl.create(CheckpointableKeyedStateBackend<K> keyedStateBackend,
ClassLoader userClassloader,
KeyContext keyContext,
ProcessingTimeService processingTimeService,
Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates)
A factory method for creating the
InternalTimeServiceManagerImpl . |
Constructor and Description |
---|
InternalTimerServiceSerializationProxy(InternalTimeServiceManagerImpl<K> timerServicesManager,
ClassLoader userCodeClassLoader,
int keyGroupIdx)
Constructor to use when restoring timer services.
|
InternalTimerServiceSerializationProxy(InternalTimeServiceManagerImpl<K> timerServicesManager,
int keyGroupIdx)
Constructor to use when writing timer services.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.