Uses of Interface
org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.BaseBackendBuilder
-
Packages that use ChangelogBackendRestoreOperation.BaseBackendBuilder Package Description org.apache.flink.state.changelog org.apache.flink.state.changelog.restore -
-
Uses of ChangelogBackendRestoreOperation.BaseBackendBuilder in org.apache.flink.state.changelog
Methods in org.apache.flink.state.changelog with parameters of type ChangelogBackendRestoreOperation.BaseBackendBuilder Modifier and Type Method Description protected abstract <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>AbstractChangelogStateBackend. restore(org.apache.flink.runtime.execution.Environment env, String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.changelog.ChangelogStateBackendHandle> stateBackendHandles, ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder)protected <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>ChangelogStateBackend. restore(org.apache.flink.runtime.execution.Environment env, String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.changelog.ChangelogStateBackendHandle> stateBackendHandles, ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder)protected <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>DeactivatedChangelogStateBackend. restore(org.apache.flink.runtime.execution.Environment env, String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.changelog.ChangelogStateBackendHandle> stateBackendHandles, ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder) -
Uses of ChangelogBackendRestoreOperation.BaseBackendBuilder in org.apache.flink.state.changelog.restore
Methods in org.apache.flink.state.changelog.restore with parameters of type ChangelogBackendRestoreOperation.BaseBackendBuilder Modifier and Type Method Description static <K> org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>ChangelogBackendRestoreOperation. restore(org.apache.flink.configuration.Configuration configuration, ClassLoader classLoader, org.apache.flink.runtime.state.TaskStateManager taskStateManager, Collection<org.apache.flink.runtime.state.changelog.ChangelogStateBackendHandle> stateHandles, ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder, ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder<K> changelogRestoreTargetBuilder)
-