org.apache.flink.runtime.state

Class LocalRecoveryDirectoryProviderImpl

java.lang.Object

org.apache.flink.runtime.state.LocalRecoveryDirectoryProviderImpl

All Implemented Interfaces:

Serializable, LocalRecoveryDirectoryProvider

public class LocalRecoveryDirectoryProviderImpl
extends Object
implements LocalRecoveryDirectoryProvider

Implementation of LocalRecoveryDirectoryProvider.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LocalRecoveryDirectoryProviderImpl(File[] allocationBaseDirs, JobID jobID, JobVertexID jobVertexID, int subtaskIndex)
LocalRecoveryDirectoryProviderImpl(File allocationBaseDir, JobID jobID, JobVertexID jobVertexID, int subtaskIndex)

Method Summary

Modifier and Type	Method and Description
File	allocationBaseDirectory(long checkpointId) Returns the local state allocation base directory for given checkpoint id w.r.t.
int	allocationBaseDirsCount() Returns the total number of allocation base directories.
File	selectAllocationBaseDirectory(int idx) Returns a specific allocation base directory.
File	selectSubtaskBaseDirectory(int idx) Returns a specific subtask base directory.
File	subtaskBaseDirectory(long checkpointId) Returns the local state directory for the owning subtask the given checkpoint id w.r.t.
File	subtaskSpecificCheckpointDirectory(long checkpointId) Returns the local state directory for the specific operator subtask and the given checkpoint id w.r.t.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalRecoveryDirectoryProviderImpl

public LocalRecoveryDirectoryProviderImpl(File allocationBaseDir,
                                          @Nonnull
                                          JobID jobID,
                                          @Nonnull
                                          JobVertexID jobVertexID,
                                          @Nonnegative
                                          int subtaskIndex)

LocalRecoveryDirectoryProviderImpl

public LocalRecoveryDirectoryProviderImpl(@Nonnull
                                          File[] allocationBaseDirs,
                                          @Nonnull
                                          JobID jobID,
                                          @Nonnull
                                          JobVertexID jobVertexID,
                                          @Nonnegative
                                          int subtaskIndex)

Method Detail

allocationBaseDirectory

public File allocationBaseDirectory(long checkpointId)

Description copied from interface: LocalRecoveryDirectoryProvider

Returns the local state allocation base directory for given checkpoint id w.r.t. our rotation over all available allocation base directories.

Specified by:

allocationBaseDirectory in interface LocalRecoveryDirectoryProvider

subtaskBaseDirectory

public File subtaskBaseDirectory(long checkpointId)

Description copied from interface: LocalRecoveryDirectoryProvider

Returns the local state directory for the owning subtask the given checkpoint id w.r.t. our rotation over all available available allocation base directories. This directory is contained in the directory returned by LocalRecoveryDirectoryProvider.allocationBaseDirectory(long) for the same checkpoint id.

Specified by:

subtaskBaseDirectory in interface LocalRecoveryDirectoryProvider

subtaskSpecificCheckpointDirectory

public File subtaskSpecificCheckpointDirectory(long checkpointId)

Description copied from interface: LocalRecoveryDirectoryProvider

Returns the local state directory for the specific operator subtask and the given checkpoint id w.r.t. our rotation over all available root dirs. This directory is contained in the directory returned by LocalRecoveryDirectoryProvider.subtaskBaseDirectory(long) for the same checkpoint id.

Specified by:

subtaskSpecificCheckpointDirectory in interface LocalRecoveryDirectoryProvider

selectAllocationBaseDirectory

public File selectAllocationBaseDirectory(int idx)

Description copied from interface: LocalRecoveryDirectoryProvider

Returns a specific allocation base directory. The index must be between 0 (incl.) and LocalRecoveryDirectoryProvider.allocationBaseDirsCount() (excl.).

Specified by:

selectAllocationBaseDirectory in interface LocalRecoveryDirectoryProvider

selectSubtaskBaseDirectory

public File selectSubtaskBaseDirectory(int idx)

Description copied from interface: LocalRecoveryDirectoryProvider

Returns a specific subtask base directory. The index must be between 0 (incl.) and LocalRecoveryDirectoryProvider.allocationBaseDirsCount() (excl.). This directory is direct a child of LocalRecoveryDirectoryProvider.selectSubtaskBaseDirectory(int) given the same index.

Specified by:

selectSubtaskBaseDirectory in interface LocalRecoveryDirectoryProvider

allocationBaseDirsCount

public int allocationBaseDirsCount()

Description copied from interface: LocalRecoveryDirectoryProvider

Returns the total number of allocation base directories.

Specified by:

allocationBaseDirsCount in interface LocalRecoveryDirectoryProvider

toString

public String toString()

Overrides:

toString in class Object