Package org.apache.flink.changelog.fs

Class FsStateChangelogStorageFactory

java.lang.Object

org.apache.flink.changelog.fs.FsStateChangelogStorageFactory

All Implemented Interfaces:

org.apache.flink.runtime.state.changelog.StateChangelogStorageFactory

@Internal
public class FsStateChangelogStorageFactory
extends Object
implements org.apache.flink.runtime.state.changelog.StateChangelogStorageFactory

FsStateChangelogStorage factory.

Field Summary

Fields

Modifier and Type	Field	Description
static String	IDENTIFIER

Constructor Summary

Constructors

Constructor	Description
FsStateChangelogStorageFactory()

Method Summary

Modifier and Type	Method	Description
static void	configure(org.apache.flink.configuration.Configuration configuration, File newFolder, java.time.Duration uploadTimeout, int maxUploadAttempts)
org.apache.flink.runtime.state.changelog.StateChangelogStorage<?>	createStorage(org.apache.flink.api.common.JobID jobID, org.apache.flink.configuration.Configuration configuration, org.apache.flink.runtime.metrics.groups.TaskManagerJobMetricGroup metricGroup, org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig)
org.apache.flink.runtime.state.changelog.StateChangelogStorageView<?>	createStorageView(org.apache.flink.configuration.Configuration configuration)
String	getIdentifier()

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()

Specified by:

getIdentifier in interface org.apache.flink.runtime.state.changelog.StateChangelogStorageFactory

createStorage

public org.apache.flink.runtime.state.changelog.StateChangelogStorage<?> createStorage(org.apache.flink.api.common.JobID jobID,
                                                                                       org.apache.flink.configuration.Configuration configuration,
                                                                                       org.apache.flink.runtime.metrics.groups.TaskManagerJobMetricGroup metricGroup,
                                                                                       org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig)
                                                                                throws IOException

Specified by:

createStorage in interface org.apache.flink.runtime.state.changelog.StateChangelogStorageFactory

Throws:

IOException

createStorageView

public org.apache.flink.runtime.state.changelog.StateChangelogStorageView<?> createStorageView(org.apache.flink.configuration.Configuration configuration)

Specified by:

createStorageView in interface org.apache.flink.runtime.state.changelog.StateChangelogStorageFactory

configure

public static void configure(org.apache.flink.configuration.Configuration configuration,
                             File newFolder,
                             java.time.Duration uploadTimeout,
                             int maxUploadAttempts)