Package | Description |
---|---|
org.apache.hadoop.hdfs.server.datanode | |
org.apache.hadoop.hdfs.server.datanode.fsdataset |
Modifier and Type | Method and Description |
---|---|
FsVolumeSpi |
ReplicaInfo.getVolume()
Get the volume where this replica is located on disk
|
Constructor and Description |
---|
FinalizedReplica(Block block,
FsVolumeSpi vol,
File dir)
Constructor
|
FinalizedReplica(long blockId,
long len,
long genStamp,
FsVolumeSpi vol,
File dir)
Constructor
|
ReplicaBeingWritten(Block block,
FsVolumeSpi vol,
File dir,
Thread writer)
Constructor
|
ReplicaBeingWritten(long blockId,
long genStamp,
FsVolumeSpi vol,
File dir)
Constructor for a zero length replica
|
ReplicaBeingWritten(long blockId,
long len,
long genStamp,
FsVolumeSpi vol,
File dir,
Thread writer)
Constructor
|
ReplicaInPipeline(long blockId,
long genStamp,
FsVolumeSpi vol,
File dir)
Constructor for a zero length replica
|
ReplicaWaitingToBeRecovered(Block block,
FsVolumeSpi vol,
File dir)
Constructor
|
ReplicaWaitingToBeRecovered(long blockId,
long len,
long genStamp,
FsVolumeSpi vol,
File dir)
Constructor
|
Modifier and Type | Class and 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 in round-robin order.
|
interface |
VolumeChoosingPolicy<V extends FsVolumeSpi>
This interface specifies the policy for choosing volumes to store replicas.
|
Modifier and Type | Method and Description |
---|---|
void |
FsDatasetSpi.checkAndUpdate(String bpid,
long blockId,
File diskFile,
File diskMetaFile,
FsVolumeSpi vol)
Check whether the in-memory block record matches the block on the disk,
and, in case that they are not matched, update the record or mark it
as corrupted.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.