Package org.apache.flink.state.changelog.restore

Class ChangelogBackendRestoreOperation

java.lang.Object

org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation

@Internal
public class ChangelogBackendRestoreOperation
extends Object

Restores ChangelogKeyedStateBackend from the provided handles.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ChangelogBackendRestoreOperation.BaseBackendBuilder<K>	Builds base backend for ChangelogKeyedStateBackend from state.
static interface	ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder<K>	Builds ChangelogRestoreTarget from the base backend and state.

Method Summary

Modifier and Type	Method	Description
static <K> CheckpointableKeyedStateBackend<K>	restore(Configuration configuration, ClassLoader classLoader, TaskStateManager taskStateManager, Collection<ChangelogStateBackendHandle> stateHandles, ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder, ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder<K> changelogRestoreTargetBuilder)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

restore

public static <K> CheckpointableKeyedStateBackend<K> restore(Configuration configuration,
                                                             ClassLoader classLoader,
                                                             TaskStateManager taskStateManager,
                                                             Collection<ChangelogStateBackendHandle> stateHandles,
                                                             ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder,
                                                             ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder<K> changelogRestoreTargetBuilder)
                                                      throws Exception

Throws:

Exception