Package | Description |
---|---|
org.apache.flink.state.api.input.operator | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.sorted.state |
Modifier and Type | Method and Description |
---|---|
void |
StateReaderOperator.setup(ExecutionConfig executionConfig,
KeyedStateBackend<KEY> keyKeyedStateBackend,
InternalTimeServiceManager<KEY> timerServiceManager,
SavepointRuntimeContext ctx) |
Modifier and Type | Class and Description |
---|---|
class |
InternalTimeServiceManagerImpl<K>
An entity keeping all the time-related services.
|
Modifier and Type | Method and Description |
---|---|
<K> InternalTimeServiceManager<K> |
InternalTimeServiceManager.Provider.create(CheckpointableKeyedStateBackend<K> keyedStatedBackend,
ClassLoader userClassloader,
KeyContext keyContext,
ProcessingTimeService processingTimeService,
Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates) |
InternalTimeServiceManager<?> |
StreamOperatorStateContext.internalTimerServiceManager()
Returns the internal timer service manager for the stream operator.
|
Modifier and Type | Method and Description |
---|---|
protected Optional<InternalTimeServiceManager<?>> |
AbstractStreamOperator.getTimeServiceManager() |
protected Optional<InternalTimeServiceManager<?>> |
AbstractStreamOperatorV2.getTimeServiceManager() |
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,
boolean isUsingCustomRawKeyedState) |
Modifier and Type | Class and Description |
---|---|
class |
BatchExecutionInternalTimeServiceManager<K>
An implementation of a
InternalTimeServiceManager that manages timers with a single
active key at a time. |
Modifier and Type | Method and Description |
---|---|
static <K> InternalTimeServiceManager<K> |
BatchExecutionInternalTimeServiceManager.create(CheckpointableKeyedStateBackend<K> keyedStatedBackend,
ClassLoader userClassloader,
KeyContext keyContext,
ProcessingTimeService processingTimeService,
Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.