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.

Constructor Summary

Constructors

Constructor and Description
LocalRecoveryConfig(LocalRecoveryDirectoryProvider directoryProvider)

Method Summary

Modifier and Type	Method and Description
Optional<LocalRecoveryDirectoryProvider>	getLocalStateDirectoryProvider()
boolean	isLocalRecoveryEnabled()
static java.util.function.Supplier<IllegalStateException>	localRecoveryNotEnabled()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalRecoveryConfig

public LocalRecoveryConfig(@Nullable
                           LocalRecoveryDirectoryProvider directoryProvider)

Method Detail

isLocalRecoveryEnabled

public boolean isLocalRecoveryEnabled()

getLocalStateDirectoryProvider

public Optional<LocalRecoveryDirectoryProvider> getLocalStateDirectoryProvider()

toString

public String toString()

Overrides:

toString in class Object

localRecoveryNotEnabled

public static java.util.function.Supplier<IllegalStateException> localRecoveryNotEnabled()