Modifier and Type | Method and Description |
---|---|
Block |
ExtendedBlock.getLocalBlock() |
static Block |
ExtendedBlock.getLocalBlock(ExtendedBlock b) |
Block |
BlockListAsLongs.BlockReportIterator.next() |
Modifier and Type | Method and Description |
---|---|
Iterator<Block> |
BlockListAsLongs.iterator()
Returns an iterator over blocks in the block report.
|
Modifier and Type | Method and Description |
---|---|
int |
Block.compareTo(Block b) |
static boolean |
Block.matchingIdAndGenStamp(Block a,
Block b) |
void |
ExtendedBlock.set(String poolId,
Block blk) |
Constructor and Description |
---|
Block(Block blk) |
ExtendedBlock(String poolId,
Block b) |
Constructor and Description |
---|
BlockListAsLongs(List<? extends Block> finalized,
List<ReplicaInfo> uc)
Create block report from finalized and under construction lists of blocks.
|
Modifier and Type | Method and Description |
---|---|
static Block |
PBHelper.convert(HdfsProtos.BlockProto b) |
Modifier and Type | Method and Description |
---|---|
static HdfsProtos.BlockProto |
PBHelper.convert(Block b) |
Modifier and Type | Class and Description |
---|---|
class |
BlockInfo
BlockInfo class maintains for a given block
the
INodeFile it is part of and datanodes where the replicas of
the block are stored. |
class |
BlockInfoUnderConstruction
Represents a block that is currently being constructed.
This is usually the last block of a file opened for write or append. |
Modifier and Type | Field and Description |
---|---|
Block |
DatanodeDescriptor.BlockTargetPair.block |
Modifier and Type | Field and Description |
---|---|
Map<String,LightWeightLinkedSet<Block>> |
BlockManager.excessReplicateMap
Maps a StorageID to the set of blocks that are "extra" for this
DataNode.
|
Modifier and Type | Method and Description |
---|---|
Block[] |
DatanodeDescriptor.getInvalidateBlocks(int maxblocks)
Remove the specified number of blocks to be invalidated
|
Modifier and Type | Method and Description |
---|---|
Iterator<Block> |
BlockManager.getCorruptReplicaBlockIterator()
Return an iterator over the set of blocks for which there are no replicas.
|
Modifier and Type | Method and Description |
---|---|
void |
CorruptReplicasMap.addToCorruptReplicasMap(Block blk,
DatanodeDescriptor dn,
String reason)
Mark the block belonging to datanode as corrupt.
|
boolean |
BlockManager.checkMinReplication(Block block) |
DatanodeDescriptor |
BlockPlacementPolicyDefault.chooseReplicaToDelete(BlockCollection bc,
Block block,
short replicationFactor,
Collection<DatanodeDescriptor> first,
Collection<DatanodeDescriptor> second) |
abstract DatanodeDescriptor |
BlockPlacementPolicy.chooseReplicaToDelete(BlockCollection srcBC,
Block block,
short replicationFactor,
Collection<DatanodeDescriptor> existingReplicas,
Collection<DatanodeDescriptor> moreExistingReplicas)
Decide whether deleting the specified replica of the block still makes
the block conform to the configured block placement policy.
|
boolean |
BlockManager.commitOrCompleteLastBlock(MutableBlockCollection bc,
Block commitBlock)
Commit the last block of the file and mark it as complete if it has
meets the minimum replication requirement
|
NumberReplicas |
BlockManager.countNodes(Block b)
Return the number of nodes hosting a given block, grouped
by the state of those replicas.
|
Iterator<DatanodeDescriptor> |
BlockManager.datanodeIterator(Block block) |
BlockCollection |
BlockManager.getBlockCollection(Block b) |
BlockInfo |
BlockManager.getStoredBlock(Block block) |
int |
BlockManager.numCorruptReplicas(Block block) |
int |
CorruptReplicasMap.numCorruptReplicas(Block blk) |
void |
BlockManager.processQueuedMessagesForBlock(Block b)
Try to process any messages that were previously queued for the given
block.
|
void |
BlockManager.removeBlock(Block block) |
void |
BlockManager.removeBlockFromMap(Block block) |
void |
BlockManager.removeStoredBlock(Block block,
DatanodeDescriptor node)
Modify (block-->datanode) map.
|
void |
BlockManager.setReplication(short oldRepl,
short newRepl,
String src,
Block... blocks)
Set replication for the blocks.
|
Constructor and Description |
---|
BlockInfo(Block blk,
int replication) |
BlockInfoUnderConstruction(Block blk,
int replication)
Create block and set its state to
HdfsServerConstants.BlockUCState.UNDER_CONSTRUCTION . |
BlockInfoUnderConstruction(Block blk,
int replication,
HdfsServerConstants.BlockUCState state,
DatanodeDescriptor[] targets)
Create a block that is currently being constructed.
|
Modifier and Type | Class and Description |
---|---|
class |
FinalizedReplica
This class describes a replica that has been finalized.
|
class |
ReplicaBeingWritten
This class represents replicas being written.
|
class |
ReplicaInfo
This class is used by datanodes to maintain meta data of its replicas.
|
class |
ReplicaInPipeline
This class defines a replica in a pipeline, which
includes a persistent replica being written to by a dfs client or
a temporary replica being replicated by a source datanode or
being copied for the balancing purpose.
|
class |
ReplicaUnderRecovery
This class represents replicas that are under block recovery
It has a recovery id that is equal to the generation stamp
that the replica will be bumped to after recovery
The recovery id is used to handle multiple concurrent block recoveries.
|
class |
ReplicaWaitingToBeRecovered
This class represents a replica that is waiting to be recovered.
|
Modifier and Type | Method and Description |
---|---|
static File |
DatanodeUtil.createTmpFile(Block b,
File f)
Create a new file.
|
void |
DataBlockScanner.deleteBlock(String poolId,
Block toDelete) |
void |
DataBlockScanner.deleteBlocks(String poolId,
Block[] toDelete) |
Constructor and Description |
---|
FinalizedReplica(Block block,
FsVolumeSpi vol,
File dir)
Constructor
|
ReplicaBeingWritten(Block block,
FsVolumeSpi vol,
File dir,
Thread writer)
Constructor
|
ReplicaWaitingToBeRecovered(Block block,
FsVolumeSpi vol,
File dir)
Constructor
|
Modifier and Type | Method and Description |
---|---|
Block |
FsDatasetSpi.getStoredBlock(String bpid,
long blkid) |
Modifier and Type | Method and Description |
---|---|
List<Block> |
FsDatasetSpi.getFinalizedBlocks(String bpid) |
Modifier and Type | Method and Description |
---|---|
void |
FsDatasetSpi.invalidate(String bpid,
Block[] invalidBlks)
Invalidates the specified blocks
|
Modifier and Type | Method and Description |
---|---|
static Block |
FSEditLogOp.blockFromXml(XMLUtils.Stanza st) |
static Block[] |
FSImageSerialization.readCompactBlockArray(DataInput in,
int logVersion) |
Modifier and Type | Method and Description |
---|---|
List<Block> |
INode.BlocksMapUpdateInfo.getToDeleteList() |
Modifier and Type | Method and Description |
---|---|
void |
INode.BlocksMapUpdateInfo.addDeleteBlock(Block toDelete)
Add a to-be-deleted block into the
INode.BlocksMapUpdateInfo.toDeleteList |
static void |
FSEditLogOp.blockToXml(ContentHandler contentHandler,
Block block) |
void |
SafeMode.decrementSafeBlockCount(Block b)
Decrement number of blocks that reached minimal replication.
|
void |
FSNamesystem.decrementSafeBlockCount(Block b) |
boolean |
Namesystem.isGenStampInFuture(Block block) |
boolean |
FSNamesystem.isGenStampInFuture(Block block) |
static void |
FSImageSerialization.writeCompactBlockArray(Block[] blocks,
DataOutputStream out)
Write an array of blocks as compactly as possible.
|
Constructor and Description |
---|
INode.BlocksMapUpdateInfo(List<Block> toDeleteList) |
Modifier and Type | Class and Description |
---|---|
class |
ReplicaRecoveryInfo
Replica recovery information.
|
Modifier and Type | Method and Description |
---|---|
Block |
BlocksWithLocations.BlockWithLocations.getBlock()
get the block
|
Block |
ReceivedDeletedBlockInfo.getBlock() |
Block[] |
BlockCommand.getBlocks() |
Modifier and Type | Method and Description |
---|---|
boolean |
ReceivedDeletedBlockInfo.blockEquals(Block b) |
void |
ReceivedDeletedBlockInfo.setBlock(Block blk) |
Constructor and Description |
---|
BlockCommand(int action,
String poolId,
Block[] blocks)
Create BlockCommand for the given action
|
BlockCommand(int action,
String poolId,
Block[] blocks,
DatanodeInfo[][] targets)
Create BlockCommand for the given action
|
BlocksWithLocations.BlockWithLocations(Block block,
String[] storageIDs)
constructor
|
ReceivedDeletedBlockInfo(Block blk,
ReceivedDeletedBlockInfo.BlockStatus status,
String delHints) |
Copyright © 2013 Apache Software Foundation. All rights reserved.