Uses of Interface
org.apache.flink.runtime.state.changelog.StateChangelogWriter

Packages that use StateChangelogWriter

Package	Description
org.apache.flink.runtime.state.changelog
org.apache.flink.state.changelog

Uses of StateChangelogWriter in org.apache.flink.runtime.state.changelog

Methods in org.apache.flink.runtime.state.changelog that return StateChangelogWriter

Modifier and Type	Method and Description
StateChangelogWriter<Handle>	StateChangelogStorage.createWriter(String operatorID, KeyGroupRange keyGroupRange, MailboxExecutor mailboxExecutor)

Uses of StateChangelogWriter in org.apache.flink.state.changelog

Constructors in org.apache.flink.state.changelog with parameters of type StateChangelogWriter

Constructor and Description
ChangelogKeyedStateBackend(AbstractKeyedStateBackend<K> keyedStateBackend, String subtaskName, ExecutionConfig executionConfig, TtlTimeProvider ttlTimeProvider, org.apache.flink.state.changelog.ChangelogStateBackendMetricGroup metricGroup, StateChangelogWriter<? extends ChangelogStateHandle> stateChangelogWriter, Collection<ChangelogStateBackendHandle> initialState, CheckpointStorageWorkerView checkpointStorageWorkerView, ChangelogStateFactory changelogStateFactory)
ChangelogKeyedStateBackend(AbstractKeyedStateBackend<K> keyedStateBackend, String subtaskName, ExecutionConfig executionConfig, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, StateChangelogWriter<? extends ChangelogStateHandle> stateChangelogWriter, Collection<ChangelogStateBackendHandle> initialState, CheckpointStorageWorkerView checkpointStorageWorkerView)