Uses of Interface
org.apache.flink.runtime.state.LocalRecoveryDirectoryProvider

Packages that use LocalRecoveryDirectoryProvider

Package	Description
org.apache.flink.runtime.state

Uses of LocalRecoveryDirectoryProvider in org.apache.flink.runtime.state

Classes in org.apache.flink.runtime.state that implement LocalRecoveryDirectoryProvider

Modifier and Type	Class	Description
class	LocalRecoveryDirectoryProviderImpl	Implementation of LocalRecoveryDirectoryProvider.

Methods in org.apache.flink.runtime.state that return LocalRecoveryDirectoryProvider

Modifier and Type	Method	Description
protected LocalRecoveryDirectoryProvider	TaskLocalStateStoreImpl.getLocalRecoveryDirectoryProvider()

Methods in org.apache.flink.runtime.state that return types with arguments of type LocalRecoveryDirectoryProvider

Modifier and Type	Method	Description
Optional<LocalRecoveryDirectoryProvider>	LocalRecoveryConfig.getLocalStateDirectoryProvider()

Methods in org.apache.flink.runtime.state with parameters of type LocalRecoveryDirectoryProvider

Modifier and Type	Method	Description
static CheckpointStreamWithResultProvider	CheckpointStreamWithResultProvider.createDuplicatingStream(long checkpointId, CheckpointedStateScope checkpointedStateScope, CheckpointStreamFactory primaryStreamFactory, LocalRecoveryDirectoryProvider secondaryStreamDirProvider)
static org.apache.flink.core.fs.Path	ChangelogTaskLocalStateStore.getLocalTaskOwnedDirectory(LocalRecoveryDirectoryProvider provider, org.apache.flink.api.common.JobID jobID)

Constructors in org.apache.flink.runtime.state with parameters of type LocalRecoveryDirectoryProvider

Constructor	Description
LocalRecoveryConfig(LocalRecoveryDirectoryProvider directoryProvider)