Uses of Interface
org.apache.hadoop.hdfs.server.datanode.fsdataset.FsVolumeSpi

Packages that use FsVolumeSpi

Package	Description
org.apache.hadoop.hdfs.protocol
org.apache.hadoop.hdfs.server.datanode
org.apache.hadoop.hdfs.server.datanode.checker	Datanode support for running disk checks.
org.apache.hadoop.hdfs.server.datanode.fsdataset
org.apache.hadoop.hdfs.server.datanode.fsdataset.impl

Uses of FsVolumeSpi in org.apache.hadoop.hdfs.protocol

Methods in org.apache.hadoop.hdfs.protocol that return FsVolumeSpi

Modifier and Type	Method	Description
FsVolumeSpi	BlockListAsLongs.BlockReportReplica.getVolume()

Uses of FsVolumeSpi in org.apache.hadoop.hdfs.server.datanode

Methods in org.apache.hadoop.hdfs.server.datanode that return FsVolumeSpi

Modifier and Type	Method	Description
FsVolumeSpi	DirectoryScanner.ScanInfoVolumeReport.getVolume()
FsVolumeSpi	Replica.getVolume()	Get the volume of replica.
FsVolumeSpi	ReplicaInfo.getVolume()

Methods in org.apache.hadoop.hdfs.server.datanode with parameters of type FsVolumeSpi

Modifier and Type	Method	Description
void	FaultInjectorFileIoEvents.beforeFileIo(FsVolumeSpi volume, FileIoProvider.OPERATION op, long len)
void	FaultInjectorFileIoEvents.beforeMetadataOp(FsVolumeSpi volume, FileIoProvider.OPERATION op)
void	DataNode.checkDiskErrorAsync(FsVolumeSpi volume)	Check if there is a disk failure asynchronously and if so, handle the error.
boolean	FileIoProvider.createFile(FsVolumeSpi volume, File f)	Create a file.
static File	DatanodeUtil.createFileWithExistsCheck(FsVolumeSpi volume, org.apache.hadoop.hdfs.protocol.Block b, File f, FileIoProvider fileIoProvider)	Create a new file.
boolean	FileIoProvider.delete(FsVolumeSpi volume, File f)	Delete a file.
boolean	FileIoProvider.deleteWithExistsCheck(FsVolumeSpi volume, File f)	Delete a file, first checking to see if it exists.
static boolean	DatanodeUtil.dirNoFilesRecursive(FsVolumeSpi volume, File dir, FileIoProvider fileIoProvider)	Checks whether there are any files anywhere in the directory tree rooted at dir (directories don't count as files). dir must exist
void	FileIoProvider.dirSync(FsVolumeSpi volume, File dir)	Sync the given directory changes to durable device.
boolean	FileIoProvider.exists(FsVolumeSpi volume, File f)	Check for file existence using File.exists().
void	FileIoProvider.flush(FsVolumeSpi volume, Flushable f)	See Flushable.flush().
boolean	FileIoProvider.fullyDelete(FsVolumeSpi volume, File dir)	Delete the given directory using FileUtil.fullyDelete(File).
FileInputStream	FileIoProvider.getFileInputStream(FsVolumeSpi volume, File f)	Create a FileInputStream using FileInputStream(File).
FileOutputStream	FileIoProvider.getFileOutputStream(FsVolumeSpi volume, File f)	Create a FileOutputStream using FileOutputStream(File, boolean).
FileOutputStream	FileIoProvider.getFileOutputStream(FsVolumeSpi volume, FileDescriptor fd)	Create a FileOutputStream using FileOutputStream(FileDescriptor).
FileOutputStream	FileIoProvider.getFileOutputStream(FsVolumeSpi volume, File f, boolean append)	Create a FileOutputStream using FileOutputStream(File, boolean).
int	FileIoProvider.getHardLinkCount(FsVolumeSpi volume, File f)	Retrieves the number of links to the specified file.
RandomAccessFile	FileIoProvider.getRandomAccessFile(FsVolumeSpi volume, File f, String mode)	Create a RandomAccessFile using RandomAccessFile(File, String).
FileInputStream	FileIoProvider.getShareDeleteFileInputStream(FsVolumeSpi volume, File f, long offset)	Create a FileInputStream using NativeIO.getShareDeleteFileDescriptor(java.io.File, long).
String[]	FileIoProvider.list(FsVolumeSpi volume, File dir)	Get a listing of the given directory using FileUtil.listFiles(File).
List<String>	FileIoProvider.listDirectory(FsVolumeSpi volume, File dir, FilenameFilter filter)	Get a listing of the given directory using IOUtils.listDirectory(File, FilenameFilter).
File[]	FileIoProvider.listFiles(FsVolumeSpi volume, File dir)	Get a listing of the given directory using FileUtil.listFiles(File).
boolean	FileIoProvider.mkdirs(FsVolumeSpi volume, File dir)	See File.mkdirs().
void	FileIoProvider.mkdirsWithExistsCheck(FsVolumeSpi volume, File dir)	Create the target directory using File.mkdirs() only if it doesn't exist already.
void	FileIoProvider.move(FsVolumeSpi volume, Path src, Path target, CopyOption... options)	Move the src file to the target using Files.move(Path, Path, CopyOption...).
void	FileIoProvider.moveFile(FsVolumeSpi volume, File src, File target)	Move the src file to the target using FileUtils.moveFile(File, File).
void	FileIoProvider.nativeCopyFileUnbuffered(FsVolumeSpi volume, File src, File target, boolean preserveFileDate)	See Storage.nativeCopyFileUnbuffered(File, File, boolean).
FileInputStream	FileIoProvider.openAndSeek(FsVolumeSpi volume, File f, long offset)	Create a FileInputStream using FileInputStream(File) and position it at the given offset.
void	FileIoProvider.posixFadvise(FsVolumeSpi volume, String identifier, FileDescriptor outFd, long offset, long length, int flags)	Call posix_fadvise on the given file descriptor.
void	BlockScanner.removeVolumeScanner(FsVolumeSpi volume)	Stops and removes a volume scanner.
void	FileIoProvider.rename(FsVolumeSpi volume, File src, File target)	Move the src file to the target using Storage.rename(File, File).
void	FileIoProvider.replaceFile(FsVolumeSpi volume, File src, File target)	Move the src file to the target using FileUtil.replaceFile(File, File).
void	DataNode.reportBadBlocks(org.apache.hadoop.hdfs.protocol.ExtendedBlock block, FsVolumeSpi volume)	Report a bad block which is hosted on the local DN.
ReplicaBuilder	ReplicaBuilder.setFsVolume(FsVolumeSpi volume)
void	FileIoProvider.sync(FsVolumeSpi volume, FileOutputStream fos)	Sync the given FileOutputStream.
void	FileIoProvider.syncFileRange(FsVolumeSpi volume, FileDescriptor outFd, long offset, long numBytes, int flags)	Call sync_file_range on the given file descriptor.
void	FileIoProvider.transferToSocketFully(FsVolumeSpi volume, org.apache.hadoop.net.SocketOutputStream sockOut, FileChannel fileCh, long position, int count, org.apache.hadoop.io.LongWritable waitTime, org.apache.hadoop.io.LongWritable transferTime)	Transfer data from a FileChannel to a SocketOutputStream.
static void	LocalReplica.truncateBlock(FsVolumeSpi volume, File blockFile, File metaFile, long oldlen, long newlen, FileIoProvider fileIoProvider)

Method parameters in org.apache.hadoop.hdfs.server.datanode with type arguments of type FsVolumeSpi

Modifier and Type	Method	Description
void	DataNode.handleVolumeFailures(Set<FsVolumeSpi> unhealthyVolumes)

Constructors in org.apache.hadoop.hdfs.server.datanode with parameters of type FsVolumeSpi

Modifier	Constructor	Description
	FinalizedProvidedReplica(long blockId, URI fileURI, long fileOffset, long blockLen, long genStamp, org.apache.hadoop.fs.PathHandle pathHandle, FsVolumeSpi volume, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem remoteFS)
	FinalizedProvidedReplica(long blockId, org.apache.hadoop.fs.Path pathPrefix, String pathSuffix, long fileOffset, long blockLen, long genStamp, org.apache.hadoop.fs.PathHandle pathHandle, FsVolumeSpi volume, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem remoteFS)
	FinalizedProvidedReplica(FileRegion fileRegion, FsVolumeSpi volume, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem remoteFS)
	FinalizedReplica(long blockId, long len, long genStamp, FsVolumeSpi vol, File dir)	Constructor.
	FinalizedReplica(long blockId, long len, long genStamp, FsVolumeSpi vol, File dir, byte[] checksum)	Constructor.
	FinalizedReplica(org.apache.hadoop.hdfs.protocol.Block block, FsVolumeSpi vol, File dir)	Constructor
	FinalizedReplica(org.apache.hadoop.hdfs.protocol.Block block, FsVolumeSpi vol, File dir, byte[] checksum)	Constructor
	LocalReplicaInPipeline(long blockId, long genStamp, FsVolumeSpi vol, File dir, long bytesToReserve)	Constructor for a zero length replica.
	ProvidedReplica(long blockId, URI fileURI, long fileOffset, long blockLen, long genStamp, org.apache.hadoop.fs.PathHandle pathHandle, FsVolumeSpi volume, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem remoteFS)	Constructor.
	ProvidedReplica(long blockId, org.apache.hadoop.fs.Path pathPrefix, String pathSuffix, long fileOffset, long blockLen, long genStamp, org.apache.hadoop.fs.PathHandle pathHandle, FsVolumeSpi volume, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem remoteFS)	Constructor.
	ReplicaBeingWritten(long blockId, long len, long genStamp, FsVolumeSpi vol, File dir, Thread writer, long bytesToReserve)	Constructor.
	ReplicaBeingWritten(long blockId, long genStamp, FsVolumeSpi vol, File dir, long bytesToReserve)	Constructor for a zero length replica.
	ReplicaBeingWritten(org.apache.hadoop.hdfs.protocol.Block block, FsVolumeSpi vol, File dir, Thread writer)	Constructor.
	ReplicaWaitingToBeRecovered(long blockId, long len, long genStamp, FsVolumeSpi vol, File dir)	Constructor
	ReplicaWaitingToBeRecovered(org.apache.hadoop.hdfs.protocol.Block block, FsVolumeSpi vol, File dir)	Constructor
	ReportCompiler(FsVolumeSpi volume)	Create a report compiler for the given volume.

Uses of FsVolumeSpi in org.apache.hadoop.hdfs.server.datanode.checker

Methods in org.apache.hadoop.hdfs.server.datanode.checker that return types with arguments of type FsVolumeSpi

Modifier and Type	Method	Description
Set<FsVolumeSpi>	DatasetVolumeChecker.checkAllVolumes(FsDatasetSpi<? extends FsVolumeSpi> dataset)	Run checks against all volumes of a dataset.

Methods in org.apache.hadoop.hdfs.server.datanode.checker with parameters of type FsVolumeSpi

Modifier and Type	Method	Description
boolean	DatasetVolumeChecker.checkVolume(FsVolumeSpi volume, DatasetVolumeChecker.Callback callback)	Check a single volume asynchronously, returning a ListenableFuture that can be used to retrieve the final result.

Method parameters in org.apache.hadoop.hdfs.server.datanode.checker with type arguments of type FsVolumeSpi

Modifier and Type	Method	Description
void	DatasetVolumeChecker.Callback.call(Set<FsVolumeSpi> healthyVolumes, Set<FsVolumeSpi> failedVolumes)
Set<FsVolumeSpi>	DatasetVolumeChecker.checkAllVolumes(FsDatasetSpi<? extends FsVolumeSpi> dataset)	Run checks against all volumes of a dataset.

Uses of FsVolumeSpi in org.apache.hadoop.hdfs.server.datanode.fsdataset

Classes in org.apache.hadoop.hdfs.server.datanode.fsdataset with type parameters of type FsVolumeSpi

Modifier and Type	Class	Description
class	AvailableSpaceVolumeChoosingPolicy<V extends FsVolumeSpi>	A DN volume choosing policy which takes into account the amount of free space on each of the available volumes when considering where to assign a new replica allocation.
interface	FsDatasetSpi<V extends FsVolumeSpi>	This is a service provider interface for the underlying storage that stores replicas for a data node.
class	RoundRobinVolumeChoosingPolicy<V extends FsVolumeSpi>	Choose volumes with the same storage type in round-robin order.
interface	VolumeChoosingPolicy<V extends FsVolumeSpi>	This interface specifies the policy for choosing volumes to store replicas.

Methods in org.apache.hadoop.hdfs.server.datanode.fsdataset that return FsVolumeSpi

Modifier and Type	Method	Description
FsVolumeSpi	FsDatasetSpi.FsVolumeReferences.get(int index)	Get the volume for a given index.
FsVolumeSpi	FsVolumeReference.getVolume()	Returns the underlying volume object.
FsVolumeSpi	FsVolumeSpi.ScanInfo.getVolume()	Returns the volume that contains the block that this object describes.

Methods in org.apache.hadoop.hdfs.server.datanode.fsdataset that return types with arguments of type FsVolumeSpi

Modifier and Type	Method	Description
Iterator<FsVolumeSpi>	FsDatasetSpi.FsVolumeReferences.iterator()

Methods in org.apache.hadoop.hdfs.server.datanode.fsdataset with parameters of type FsVolumeSpi

Modifier and Type	Method	Description
ReplicaInfo	FsDatasetSpi.moveBlockAcrossVolumes(org.apache.hadoop.hdfs.protocol.ExtendedBlock block, FsVolumeSpi destination)	Moves a given block from one volume to another volume.

Method parameters in org.apache.hadoop.hdfs.server.datanode.fsdataset with type arguments of type FsVolumeSpi

Modifier and Type	Method	Description
void	FsDatasetSpi.handleVolumeFailures(Set<FsVolumeSpi> failedVolumes)	Check if all the data directories are healthy

Constructors in org.apache.hadoop.hdfs.server.datanode.fsdataset with parameters of type FsVolumeSpi

Modifier	Constructor	Description
	ReplicaOutputStreams(OutputStream dataOut, OutputStream checksumOut, org.apache.hadoop.util.DataChecksum checksum, FsVolumeSpi volume, FileIoProvider fileIoProvider)	Create an object with a data output stream, a checksum output stream and a checksum.
	ScanInfo(long blockId, File basePath, String blockFile, String metaFile, FsVolumeSpi vol)	Create a ScanInfo object for a block.
	ScanInfo(long blockId, FsVolumeSpi vol, FileRegion fileRegion, long length)	Create a ScanInfo object for a block.

Uses of FsVolumeSpi in org.apache.hadoop.hdfs.server.datanode.fsdataset.impl

Classes in org.apache.hadoop.hdfs.server.datanode.fsdataset.impl that implement FsVolumeSpi

Modifier and Type	Class	Description
class	FsVolumeImpl	The underlying volume used to store replica.

Methods in org.apache.hadoop.hdfs.server.datanode.fsdataset.impl that return types with arguments of type FsVolumeSpi

Modifier and Type	Method	Description
FsDatasetSpi<? extends FsVolumeSpi>	FsVolumeImpl.getDataset()
Map<FsVolumeSpi,IOException>	AddBlockPoolException.getFailingVolumes()

Constructor parameters in org.apache.hadoop.hdfs.server.datanode.fsdataset.impl with type arguments of type FsVolumeSpi

Modifier	Constructor	Description
	AddBlockPoolException(Map<FsVolumeSpi,IOException> unhealthyDataDirs)