Uses of Class
org.apache.flink.runtime.state.FileMergingSnapshotManagerClosableWrapper
-
Packages that use FileMergingSnapshotManagerClosableWrapper Package Description org.apache.flink.runtime.state -
-
Uses of FileMergingSnapshotManagerClosableWrapper in org.apache.flink.runtime.state
Methods in org.apache.flink.runtime.state that return FileMergingSnapshotManagerClosableWrapper Modifier and Type Method Description static FileMergingSnapshotManagerClosableWrapper
FileMergingSnapshotManagerClosableWrapper. of(FileMergingSnapshotManager snapshotManager, Closeable closeable)
Constructors in org.apache.flink.runtime.state with parameters of type FileMergingSnapshotManagerClosableWrapper 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)
-