Uses of Class
org.apache.flink.state.changelog.ChangelogStateFactory
-
Packages that use ChangelogStateFactory Package Description org.apache.flink.state.changelog org.apache.flink.state.changelog.restore -
-
Uses of ChangelogStateFactory in org.apache.flink.state.changelog
Constructors in org.apache.flink.state.changelog with parameters of type ChangelogStateFactory Constructor Description ChangelogKeyedStateBackend(org.apache.flink.runtime.state.AbstractKeyedStateBackend<K> keyedStateBackend, String subtaskName, org.apache.flink.api.common.ExecutionConfig executionConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.state.changelog.ChangelogStateBackendMetricGroup metricGroup, org.apache.flink.runtime.state.changelog.StateChangelogWriter<? extends org.apache.flink.runtime.state.changelog.ChangelogStateHandle> stateChangelogWriter, Collection<org.apache.flink.runtime.state.changelog.ChangelogStateBackendHandle> initialState, org.apache.flink.runtime.state.CheckpointStorageWorkerView checkpointStorageWorkerView, ChangelogStateFactory changelogStateFactory) -
Uses of ChangelogStateFactory in org.apache.flink.state.changelog.restore
Constructors in org.apache.flink.state.changelog.restore with parameters of type ChangelogStateFactory Constructor Description ChangelogMigrationRestoreTarget(org.apache.flink.runtime.state.AbstractKeyedStateBackend<K> keyedStateBackend, ChangelogStateFactory changelogStateFactory)
-