Package org.apache.flink.changelog.fs
Class FsStateChangelogStorageForRecovery
- java.lang.Object
-
- org.apache.flink.changelog.fs.FsStateChangelogStorageForRecovery
-
- All Implemented Interfaces:
AutoCloseable,org.apache.flink.runtime.state.changelog.StateChangelogStorageView<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl>
- Direct Known Subclasses:
FsStateChangelogStorage
@Experimental @ThreadSafe public class FsStateChangelogStorageForRecovery extends Object implements org.apache.flink.runtime.state.changelog.StateChangelogStorageView<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl>
Filesystem-based implementation ofStateChangelogStoragejust for recovery.
-
-
Constructor Summary
Constructors Constructor Description FsStateChangelogStorageForRecovery(org.apache.flink.changelog.fs.ChangelogStreamHandleReader changelogStreamHandleReader)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()org.apache.flink.runtime.state.changelog.StateChangelogHandleReader<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl>createReader()
-
-
-
Method Detail
-
createReader
public org.apache.flink.runtime.state.changelog.StateChangelogHandleReader<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl> createReader()
- Specified by:
createReaderin interfaceorg.apache.flink.runtime.state.changelog.StateChangelogStorageView<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl>
-
close
public void close() throws Exception- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceorg.apache.flink.runtime.state.changelog.StateChangelogStorageView<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl>- Throws:
Exception
-
-