org.apache.flink.runtime.state

Class LocalRecoveryConfig

java.lang.Object

org.apache.flink.runtime.state.LocalRecoveryConfig

public class LocalRecoveryConfig
extends Object

This class encapsulates the completed configuration for local recovery, i.e. the root directories into which all file-based snapshots can be written and the general mode for the local recover feature.

Field Summary

Fields

Modifier and Type	Field and Description
static LocalRecoveryConfig	BACKUP_AND_RECOVERY_DISABLED

Constructor Summary

Constructors

Constructor and Description
LocalRecoveryConfig(boolean localRecoveryEnabled, boolean localBackupEnabled, LocalSnapshotDirectoryProvider directoryProvider)

Method Summary

Modifier and Type	Method and Description
static LocalRecoveryConfig	backupAndRecoveryEnabled(LocalSnapshotDirectoryProvider directoryProvider)
Optional<LocalSnapshotDirectoryProvider>	getLocalStateDirectoryProvider()
boolean	isLocalBackupEnabled()
boolean	isLocalRecoveryEnabled()
boolean	isLocalRecoveryOrLocalBackupEnabled()
static Supplier<IllegalStateException>	localRecoveryNotEnabled()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

BACKUP_AND_RECOVERY_DISABLED

public static final LocalRecoveryConfig BACKUP_AND_RECOVERY_DISABLED

Constructor Detail

LocalRecoveryConfig

public LocalRecoveryConfig(boolean localRecoveryEnabled,
                           boolean localBackupEnabled,
                           @Nullable
                           LocalSnapshotDirectoryProvider directoryProvider)

Method Detail

isLocalRecoveryEnabled

public boolean isLocalRecoveryEnabled()

isLocalBackupEnabled

public boolean isLocalBackupEnabled()

isLocalRecoveryOrLocalBackupEnabled

public boolean isLocalRecoveryOrLocalBackupEnabled()

getLocalStateDirectoryProvider

public Optional<LocalSnapshotDirectoryProvider> getLocalStateDirectoryProvider()

toString

public String toString()

Overrides:

toString in class Object

localRecoveryNotEnabled

public static Supplier<IllegalStateException> localRecoveryNotEnabled()

backupAndRecoveryEnabled

public static LocalRecoveryConfig backupAndRecoveryEnabled(@Nonnull
                                                           LocalSnapshotDirectoryProvider directoryProvider)