org.apache.flink.runtime.state.changelog

Interface StateChangelogStorage<Handle extends ChangelogStateHandle>

All Superinterfaces:

AutoCloseable, StateChangelogStorageView<Handle>

All Known Implementing Classes:

FsStateChangelogStorage, InMemoryStateChangelogStorage

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

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

Method Summary

Modifier and Type	Method and Description
StateChangelogWriter<Handle>	createWriter(String operatorID, KeyGroupRange keyGroupRange, MailboxExecutor mailboxExecutor)
default AvailabilityProvider	getAvailabilityProvider()

Methods inherited from interface org.apache.flink.runtime.state.changelog.StateChangelogStorageView

close, createReader

Method Detail

createWriter

StateChangelogWriter<Handle> createWriter(String operatorID,
                                          KeyGroupRange keyGroupRange,
                                          MailboxExecutor mailboxExecutor)

getAvailabilityProvider

default AvailabilityProvider getAvailabilityProvider()