public class LocalSnapshotDirectoryProviderImpl extends Object implements LocalSnapshotDirectoryProvider
LocalSnapshotDirectoryProvider
.Constructor and Description |
---|
LocalSnapshotDirectoryProviderImpl(File[] allocationBaseDirs,
JobID jobID,
JobVertexID jobVertexID,
int subtaskIndex) |
LocalSnapshotDirectoryProviderImpl(File allocationBaseDir,
JobID jobID,
JobVertexID jobVertexID,
int subtaskIndex) |
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() |
public LocalSnapshotDirectoryProviderImpl(File allocationBaseDir, @Nonnull JobID jobID, @Nonnull JobVertexID jobVertexID, @Nonnegative int subtaskIndex)
public LocalSnapshotDirectoryProviderImpl(@Nonnull File[] allocationBaseDirs, @Nonnull JobID jobID, @Nonnull JobVertexID jobVertexID, @Nonnegative int subtaskIndex)
public File allocationBaseDirectory(long checkpointId)
LocalSnapshotDirectoryProvider
allocationBaseDirectory
in interface LocalSnapshotDirectoryProvider
public File subtaskBaseDirectory(long checkpointId)
LocalSnapshotDirectoryProvider
LocalSnapshotDirectoryProvider.allocationBaseDirectory(long)
for the same
checkpoint id.subtaskBaseDirectory
in interface LocalSnapshotDirectoryProvider
public File subtaskSpecificCheckpointDirectory(long checkpointId)
LocalSnapshotDirectoryProvider
LocalSnapshotDirectoryProvider.subtaskBaseDirectory(long)
for the same checkpoint id.subtaskSpecificCheckpointDirectory
in interface LocalSnapshotDirectoryProvider
public File selectAllocationBaseDirectory(int idx)
LocalSnapshotDirectoryProvider
LocalSnapshotDirectoryProvider.allocationBaseDirsCount()
(excl.).selectAllocationBaseDirectory
in interface LocalSnapshotDirectoryProvider
public File selectSubtaskBaseDirectory(int idx)
LocalSnapshotDirectoryProvider
LocalSnapshotDirectoryProvider.allocationBaseDirsCount()
(excl.). This directory is direct a child of LocalSnapshotDirectoryProvider.selectSubtaskBaseDirectory(int)
given the same index.selectSubtaskBaseDirectory
in interface LocalSnapshotDirectoryProvider
public int allocationBaseDirsCount()
LocalSnapshotDirectoryProvider
allocationBaseDirsCount
in interface LocalSnapshotDirectoryProvider
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.