org.apache.flink.runtime.state.changelog

Class StateChangelogStorageLoader

java.lang.Object

org.apache.flink.runtime.state.changelog.StateChangelogStorageLoader

@Internal
public class StateChangelogStorageLoader
extends Object

A thin wrapper around PluginManager to load StateChangelogStorage.

Constructor Summary

Constructors

Constructor and Description
StateChangelogStorageLoader()

Method Summary

Modifier and Type	Method and Description
static void	initialize(PluginManager pluginManager)
static StateChangelogStorage<?>	load(JobID jobID, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig)
static StateChangelogStorageView<?>	loadFromStateHandle(Configuration configuration, ChangelogStateHandle changelogStateHandle)

Methods inherited from class java.lang.Object

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

Constructor Detail

StateChangelogStorageLoader

public StateChangelogStorageLoader()

Method Detail

initialize

public static void initialize(PluginManager pluginManager)

load

@Nullable
public static StateChangelogStorage<?> load(JobID jobID,
                                                      Configuration configuration,
                                                      TaskManagerJobMetricGroup metricGroup,
                                                      LocalRecoveryConfig localRecoveryConfig)
                                               throws IOException

Throws:

IOException

loadFromStateHandle

@Nonnull
public static StateChangelogStorageView<?> loadFromStateHandle(Configuration configuration,
                                                                        ChangelogStateHandle changelogStateHandle)
                                                                 throws IOException

Throws:

IOException