Modifier and Type | Field and Description |
---|---|
static Comparator<DatanodeInfo> |
DFSUtil.DECOM_COMPARATOR
Compartor for sorting DataNodeInfo[] based on decommissioned states.
|
Modifier and Type | Method and Description |
---|---|
DatanodeInfo[] |
DFSClient.datanodeReport(HdfsConstants.DatanodeReportType type) |
DatanodeInfo |
DFSInputStream.getCurrentDatanode()
Returns the datanode from which the stream is currently reading.
|
DatanodeInfo[] |
DistributedFileSystem.getDataNodeStats() |
DatanodeInfo[] |
DistributedFileSystem.getDataNodeStats(HdfsConstants.DatanodeReportType type) |
DatanodeInfo[] |
DFSOutputStream.getPipeline() |
Modifier and Type | Method and Description |
---|---|
int |
DFSUtil.DecomStaleComparator.compare(DatanodeInfo a,
DatanodeInfo b) |
protected BlockReader |
DFSInputStream.getBlockReader(InetSocketAddress dnAddr,
DatanodeInfo chosenNode,
String file,
ExtendedBlock block,
Token<BlockTokenIdentifier> blockToken,
long startOffset,
long len,
int bufferSize,
boolean verifyChecksum,
String clientName)
Retrieve a BlockReader suitable for reading.
|
Modifier and Type | Method and Description |
---|---|
DatanodeInfo |
HdfsDataInputStream.getCurrentDatanode()
Get the datanode from which the stream is currently reading.
|
Modifier and Type | Method and Description |
---|---|
DatanodeInfo[] |
ClientProtocol.getDatanodeReport(HdfsConstants.DatanodeReportType type)
Get a report on the system's current datanodes.
|
DatanodeInfo[] |
LocatedBlock.getLocations() |
Modifier and Type | Method and Description |
---|---|
LocatedBlock |
ClientProtocol.addBlock(String src,
String clientName,
ExtendedBlock previous,
DatanodeInfo[] excludeNodes,
long fileId,
String[] favoredNodes)
A client that wants to write an additional block to the
indicated filename (which must currently be open for writing)
should call addBlock().
|
LocatedBlock |
ClientProtocol.getAdditionalDatanode(String src,
ExtendedBlock blk,
DatanodeInfo[] existings,
DatanodeInfo[] excludes,
int numAdditionalNodes,
String clientName)
Get a datanode for an existing pipeline.
|
LocatedBlock |
ClientProtocol.getAdditionalDatanode(String src,
ExtendedBlock blk,
DatanodeInfo[] existings,
DatanodeInfo[] excludes,
int numAdditionalNodes,
String clientName)
Get a datanode for an existing pipeline.
|
Constructor and Description |
---|
DatanodeInfo(DatanodeInfo from) |
LocatedBlock(ExtendedBlock b,
DatanodeInfo[] locs) |
LocatedBlock(ExtendedBlock b,
DatanodeInfo[] locs,
long startOffset) |
LocatedBlock(ExtendedBlock b,
DatanodeInfo[] locs,
long startOffset,
boolean corrupt) |
UnregisteredNodeException(DatanodeID nodeID,
DatanodeInfo storedNode)
The exception is thrown if a different data-node claims the same
storage id as the existing one.
|
Modifier and Type | Method and Description |
---|---|
void |
Sender.replaceBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String delHint,
DatanodeInfo source) |
void |
DataTransferProtocol.replaceBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String delHint,
DatanodeInfo source)
Receive a block from a source datanode
and then notifies the namenode
to remove the copy from the original datanode.
|
boolean |
ReplaceDatanodeOnFailure.satisfy(short replication,
DatanodeInfo[] existings,
boolean isAppend,
boolean isHflushed)
Is the policy satisfied?
|
void |
Sender.transferBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets) |
void |
DataTransferProtocol.transferBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets)
Transfer a block to another datanode.
|
void |
Sender.writeBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets,
DatanodeInfo source,
BlockConstructionStage stage,
int pipelineSize,
long minBytesRcvd,
long maxBytesRcvd,
long latestGenerationStamp,
DataChecksum requestedChecksum,
CachingStrategy cachingStrategy) |
void |
Sender.writeBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets,
DatanodeInfo source,
BlockConstructionStage stage,
int pipelineSize,
long minBytesRcvd,
long maxBytesRcvd,
long latestGenerationStamp,
DataChecksum requestedChecksum,
CachingStrategy cachingStrategy) |
void |
DataTransferProtocol.writeBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets,
DatanodeInfo source,
BlockConstructionStage stage,
int pipelineSize,
long minBytesRcvd,
long maxBytesRcvd,
long latestGenerationStamp,
DataChecksum requestedChecksum,
CachingStrategy cachingStrategy)
Write a block to a datanode pipeline.
|
void |
DataTransferProtocol.writeBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets,
DatanodeInfo source,
BlockConstructionStage stage,
int pipelineSize,
long minBytesRcvd,
long maxBytesRcvd,
long latestGenerationStamp,
DataChecksum requestedChecksum,
CachingStrategy cachingStrategy)
Write a block to a datanode pipeline.
|
Modifier and Type | Method and Description |
---|---|
static DatanodeInfo |
PBHelper.convert(HdfsProtos.DatanodeInfoProto di) |
static DatanodeInfo[] |
PBHelper.convert(HdfsProtos.DatanodeInfoProto[] di) |
static DatanodeInfo[] |
PBHelper.convert(HdfsProtos.DatanodeInfosProto datanodeInfosProto) |
static DatanodeInfo[] |
PBHelper.convert(List<HdfsProtos.DatanodeInfoProto> list) |
DatanodeInfo[] |
ClientNamenodeProtocolTranslatorPB.getDatanodeReport(HdfsConstants.DatanodeReportType type) |
Modifier and Type | Method and Description |
---|---|
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.addBlock(String src,
String clientName,
ExtendedBlock previous,
DatanodeInfo[] excludeNodes,
long fileId,
String[] favoredNodes) |
static HdfsProtos.DatanodeInfoProto |
PBHelper.convert(DatanodeInfo info) |
static List<? extends HdfsProtos.DatanodeInfoProto> |
PBHelper.convert(DatanodeInfo[] dnInfos) |
static List<? extends HdfsProtos.DatanodeInfoProto> |
PBHelper.convert(DatanodeInfo[] dnInfos,
int startIdx)
Copy from
dnInfos to a target of list of same size starting at
startIdx . |
static HdfsProtos.DatanodeInfoProto |
PBHelper.convertDatanodeInfo(DatanodeInfo di) |
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.getAdditionalDatanode(String src,
ExtendedBlock blk,
DatanodeInfo[] existings,
DatanodeInfo[] excludes,
int numAdditionalNodes,
String clientName) |
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.getAdditionalDatanode(String src,
ExtendedBlock blk,
DatanodeInfo[] existings,
DatanodeInfo[] excludes,
int numAdditionalNodes,
String clientName) |
BlocksWithLocations |
NamenodeProtocolTranslatorPB.getBlocks(DatanodeInfo datanode,
long size) |
Modifier and Type | Class and Description |
---|---|
class |
DatanodeDescriptor
This class extends the DatanodeInfo class with ephemeral information (eg
health, capacity, what blocks are associated with the Datanode) that is
private to the Namenode, ie this class is not exposed to clients.
|
Modifier and Type | Method and Description |
---|---|
void |
BlockPlacementPolicy.adjustSetsWithChosenReplica(Map<String,List<DatanodeDescriptor>> rackMap,
List<DatanodeDescriptor> moreThanOne,
List<DatanodeDescriptor> exactlyOne,
DatanodeInfo cur)
Adjust rackmap, moreThanOne, and exactlyOne after removing replica on cur.
|
void |
BlockManager.findAndMarkBlockAsCorrupt(ExtendedBlock blk,
DatanodeInfo dn,
String reason)
Mark the block belonging to datanode as corrupt
|
protected String |
BlockPlacementPolicy.getRack(DatanodeInfo datanode)
Get rack string from a data node
|
protected String |
BlockPlacementPolicyWithNodeGroup.getRack(DatanodeInfo cur) |
Modifier and Type | Method and Description |
---|---|
static DatanodeInfo |
JspHelper.bestNode(DatanodeInfo[] nodes,
boolean doRandom,
Configuration conf) |
static DatanodeInfo |
JspHelper.bestNode(LocatedBlock blk,
Configuration conf) |
static DatanodeInfo |
JspHelper.bestNode(LocatedBlocks blks,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
static DatanodeInfo |
JspHelper.bestNode(DatanodeInfo[] nodes,
boolean doRandom,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
DataNode.reportRemoteBadBlock(DatanodeInfo srcDataNode,
ExtendedBlock block)
Report a bad block on another DN (eg if we received a corrupt replica
from a remote host).
|
Modifier and Type | Method and Description |
---|---|
DatanodeInfo[][] |
BlockCommand.getTargets() |
Modifier and Type | Method and Description |
---|---|
BlocksWithLocations |
NamenodeProtocol.getBlocks(DatanodeInfo datanode,
long size)
Get a list of blocks belonging to
datanode
whose total size equals size . |
Constructor and Description |
---|
BlockCommand(int action,
String poolId,
Block[] blocks,
DatanodeInfo[][] targets)
Create BlockCommand for the given action
|
BlockRecoveryCommand.RecoveringBlock(ExtendedBlock b,
DatanodeInfo[] locs,
long newGS)
Create RecoveringBlock.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.