@Internal public class StateChangelogStorageLoader extends Object
PluginManager
to load StateChangelogStorage
.Constructor and Description |
---|
StateChangelogStorageLoader() |
Modifier and Type | Method and Description |
---|---|
static void |
initialize(PluginManager pluginManager) |
static StateChangelogStorage<?> |
load(Configuration configuration,
TaskManagerJobMetricGroup metricGroup) |
public static void initialize(PluginManager pluginManager)
@Nullable public static StateChangelogStorage<?> load(Configuration configuration, TaskManagerJobMetricGroup metricGroup) throws IOException
IOException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.