Package 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 Description LocalRecoveryConfig(LocalRecoveryDirectoryProvider directoryProvider)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Optional<LocalRecoveryDirectoryProvider>getLocalStateDirectoryProvider()booleanisLocalRecoveryEnabled()static java.util.function.Supplier<IllegalStateException>localRecoveryNotEnabled()StringtoString()
-
-
-
Constructor Detail
-
LocalRecoveryConfig
public LocalRecoveryConfig(@Nullable LocalRecoveryDirectoryProvider directoryProvider)
-
-
Method Detail
-
isLocalRecoveryEnabled
public boolean isLocalRecoveryEnabled()
-
getLocalStateDirectoryProvider
public Optional<LocalRecoveryDirectoryProvider> getLocalStateDirectoryProvider()
-
localRecoveryNotEnabled
public static java.util.function.Supplier<IllegalStateException> localRecoveryNotEnabled()
-
-