Package | Description |
---|---|
org.apache.flink.runtime.state |
Constructor and Description |
---|
TaskStateManagerImpl(JobID jobId,
ExecutionAttemptID executionAttemptID,
TaskLocalStateStore localStateStore,
FileMergingSnapshotManagerClosableWrapper fileMergingSnapshotManager,
StateChangelogStorage<?> stateChangelogStorage,
TaskExecutorStateChangelogStoragesManager changelogStoragesManager,
JobManagerTaskRestore jobManagerTaskRestore,
CheckpointResponder checkpointResponder,
SequentialChannelStateReaderImpl sequentialChannelStateReader) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.