@InterfaceAudience.Private public class CorruptReplicasMap extends Object
Constructor and Description |
---|
CorruptReplicasMap() |
Modifier and Type | Method and Description |
---|---|
void |
addToCorruptReplicasMap(Block blk,
DatanodeDescriptor dn,
String reason)
Mark the block belonging to datanode as corrupt.
|
int |
numCorruptReplicas(Block blk) |
int |
size() |
public void addToCorruptReplicasMap(Block blk, DatanodeDescriptor dn, String reason)
blk
- Block to be added to CorruptReplicasMapdn
- DatanodeDescriptor which holds the corrupt replicareason
- a textual reason (for logging purposes)public int numCorruptReplicas(Block blk)
public int size()
Copyright © 2013 Apache Software Foundation. All rights reserved.