@Internal public interface StateChangelogStorageFactory
StateChangelogStorage
. Please use StateChangelogStorageLoader
to
create StateChangelogStorage
.Modifier and Type | Method and Description |
---|---|
StateChangelogStorage<?> |
createStorage(Configuration configuration,
TaskManagerJobMetricGroup metricGroup)
Create the storage based on a configuration.
|
String |
getIdentifier()
Get the identifier for user to use this changelog storage factory.
|
String getIdentifier()
StateChangelogStorage<?> createStorage(Configuration configuration, TaskManagerJobMetricGroup metricGroup) throws IOException
IOException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.