Uses of Class
org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager
-
Packages that use TaskExecutorStateChangelogStoragesManager Package Description org.apache.flink.runtime.state org.apache.flink.runtime.taskexecutor -
-
Uses of TaskExecutorStateChangelogStoragesManager in org.apache.flink.runtime.state
Constructors in org.apache.flink.runtime.state with parameters of type TaskExecutorStateChangelogStoragesManager Constructor Description TaskStateManagerImpl(JobID jobId, ExecutionAttemptID executionAttemptID, TaskLocalStateStore localStateStore, FileMergingSnapshotManagerClosableWrapper fileMergingSnapshotManager, StateChangelogStorage<?> stateChangelogStorage, TaskExecutorStateChangelogStoragesManager changelogStoragesManager, JobManagerTaskRestore jobManagerTaskRestore, CheckpointResponder checkpointResponder)TaskStateManagerImpl(JobID jobId, ExecutionAttemptID executionAttemptID, TaskLocalStateStore localStateStore, FileMergingSnapshotManagerClosableWrapper fileMergingSnapshotManager, StateChangelogStorage<?> stateChangelogStorage, TaskExecutorStateChangelogStoragesManager changelogStoragesManager, JobManagerTaskRestore jobManagerTaskRestore, CheckpointResponder checkpointResponder, SequentialChannelStateReaderImpl sequentialChannelStateReader) -
Uses of TaskExecutorStateChangelogStoragesManager in org.apache.flink.runtime.taskexecutor
Methods in org.apache.flink.runtime.taskexecutor that return TaskExecutorStateChangelogStoragesManager Modifier and Type Method Description TaskExecutorStateChangelogStoragesManagerTaskManagerServices. getTaskManagerChangelogManager()
-