Class 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 of StateChangelogStorage just for recovery.
    • Constructor Detail

      • FsStateChangelogStorageForRecovery

        public FsStateChangelogStorageForRecovery​(org.apache.flink.changelog.fs.ChangelogStreamHandleReader changelogStreamHandleReader)
    • Method Detail

      • createReader

        public org.apache.flink.runtime.state.changelog.StateChangelogHandleReader<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl> createReader()
        Specified by:
        createReader in interface org.apache.flink.runtime.state.changelog.StateChangelogStorageView<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl>
      • close

        public void close()
                   throws Exception
        Specified by:
        close in interface AutoCloseable
        Specified by:
        close in interface org.apache.flink.runtime.state.changelog.StateChangelogStorageView<org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl>
        Throws:
        Exception