@Internal public class FsStateChangelogStorageFactory extends Object implements StateChangelogStorageFactory
FsStateChangelogStorage
factory.Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
Constructor and Description |
---|
FsStateChangelogStorageFactory() |
Modifier and Type | Method and Description |
---|---|
static void |
configure(Configuration configuration,
File newFolder) |
StateChangelogStorage<?> |
createStorage(Configuration configuration)
Create the storage based on a configuration.
|
String |
getIdentifier()
Get the identifier for user to use this changelog storage factory.
|
public static final String IDENTIFIER
public String getIdentifier()
StateChangelogStorageFactory
getIdentifier
in interface StateChangelogStorageFactory
public StateChangelogStorage<?> createStorage(Configuration configuration) throws IOException
StateChangelogStorageFactory
createStorage
in interface StateChangelogStorageFactory
IOException
public static void configure(Configuration configuration, File newFolder)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.