org.apache.flink.runtime.state.changelog

Interface StateChangelogStorageView<Handle extends ChangelogStateHandle>

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

StateChangelogStorage<Handle>

All Known Implementing Classes:

FsStateChangelogStorage, FsStateChangelogStorageForRecovery, InMemoryStateChangelogStorage

@Internal
public interface StateChangelogStorageView<Handle extends ChangelogStateHandle>
extends AutoCloseable

A storage view for changelog. Could produce StateChangelogHandleReader for read. Please use StateChangelogStorageLoader to obtain an instance.

Method Summary

Modifier and Type	Method and Description
default void	close()
StateChangelogHandleReader<Handle>	createReader()

Method Detail

createReader

StateChangelogHandleReader<Handle> createReader()

close

default void close()
            throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception