org.apache.flink.changelog.fs

Class FsStateChangelogStorageFactory

java.lang.Object

org.apache.flink.changelog.fs.FsStateChangelogStorageFactory

All Implemented Interfaces:

StateChangelogStorageFactory

@Internal
public class FsStateChangelogStorageFactory
extends Object
implements StateChangelogStorageFactory

FsStateChangelogStorage factory.

Field Summary

Fields

Modifier and Type	Field and Description
static String	IDENTIFIER

Constructor Summary

Constructors

Constructor and Description
FsStateChangelogStorageFactory()

Method Summary

Modifier and Type	Method and Description
static void	configure(Configuration configuration, File newFolder, Duration uploadTimeout, int maxUploadAttempts)
StateChangelogStorage<?>	createStorage(JobID jobID, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig) Create the storage based on a configuration.
StateChangelogStorageView<?>	createStorageView(Configuration configuration) Create the storage for recovery.
String	getIdentifier() Get the identifier for user to use this changelog storage factory.

Methods inherited from class java.lang.Object

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

Field Detail

IDENTIFIER

public static final String IDENTIFIER

See Also:

Constant Field Values

Constructor Detail

FsStateChangelogStorageFactory

public FsStateChangelogStorageFactory()

Method Detail

getIdentifier

public String getIdentifier()

Description copied from interface: StateChangelogStorageFactory

Get the identifier for user to use this changelog storage factory.

Specified by:

getIdentifier in interface StateChangelogStorageFactory

createStorage

public StateChangelogStorage<?> createStorage(JobID jobID,
                                              Configuration configuration,
                                              TaskManagerJobMetricGroup metricGroup,
                                              LocalRecoveryConfig localRecoveryConfig)
                                       throws IOException

Description copied from interface: StateChangelogStorageFactory

Create the storage based on a configuration.

Specified by:

createStorage in interface StateChangelogStorageFactory

Throws:

IOException

createStorageView

public StateChangelogStorageView<?> createStorageView(Configuration configuration)

Description copied from interface: StateChangelogStorageFactory

Create the storage for recovery.

Specified by:

createStorageView in interface StateChangelogStorageFactory

configure

public static void configure(Configuration configuration,
                             File newFolder,
                             Duration uploadTimeout,
                             int maxUploadAttempts)