Package | Description |
---|---|
org.apache.hadoop.fs |
An abstract file system API.
|
org.apache.hadoop.hdfs |
A distributed implementation of
FileSystem . |
org.apache.hadoop.hdfs.client | |
org.apache.hadoop.hdfs.protocol | |
org.apache.hadoop.hdfs.protocolPB | |
org.apache.hadoop.hdfs.server.blockmanagement | |
org.apache.hadoop.hdfs.server.common | |
org.apache.hadoop.hdfs.server.protocol |
Modifier and Type | Method and Description |
---|---|
LocatedBlock |
HdfsBlockLocation.getLocatedBlock() |
Constructor and Description |
---|
HdfsBlockLocation(BlockLocation loc,
LocatedBlock block) |
Modifier and Type | Method and Description |
---|---|
List<LocatedBlock> |
DFSInputStream.getAllBlocks()
Return collection of blocks that has already been located.
|
Modifier and Type | Method and Description |
---|---|
static ClientDatanodeProtocol |
DFSUtil.createClientDatanodeProtocolProxy(DatanodeID datanodeid,
Configuration conf,
int socketTimeout,
boolean connectToDnViaHostname,
LocatedBlock locatedBlock)
Create a
ClientDatanodeProtocol proxy |
void |
DFSClient.reportBadBlocks(LocatedBlock[] blocks)
Report corrupt blocks that were discovered by the client.
|
Modifier and Type | Method and Description |
---|---|
static BlockLocation[] |
DFSUtil.locatedBlocks2Locations(List<LocatedBlock> blocks)
Convert a List
|
Modifier and Type | Method and Description |
---|---|
List<LocatedBlock> |
HdfsDataInputStream.getAllBlocks()
Get the collection of blocks that has already been located.
|
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.append(String src,
String clientName)
Append to the end of the file.
|
LocatedBlock |
LocatedBlocks.get(int index)
Get located block.
|
LocatedBlock |
ClientProtocol.getAdditionalDatanode(String src,
ExtendedBlock blk,
DatanodeInfo[] existings,
DatanodeInfo[] excludes,
int numAdditionalNodes,
String clientName)
Get a datanode for an existing pipeline.
|
LocatedBlock |
LocatedBlocks.getLastLocatedBlock()
Get the last located block.
|
LocatedBlock |
ClientProtocol.updateBlockForPipeline(ExtendedBlock block,
String clientName)
Get a new generation stamp together with an access token for
a block under construction
This method is called only when a client needs to recover a failed
pipeline or set up a pipeline for appending to a block.
|
Modifier and Type | Method and Description |
---|---|
List<LocatedBlock> |
LocatedBlocks.getLocatedBlocks()
Get located blocks.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientProtocol.reportBadBlocks(LocatedBlock[] blocks)
The client wants to report corrupted blocks (blocks with specified
locations on datanodes).
|
Modifier and Type | Method and Description |
---|---|
void |
LocatedBlocks.insertRange(int blockIdx,
List<LocatedBlock> newBlocks) |
Constructor and Description |
---|
LocatedBlocks(long flength,
boolean isUnderConstuction,
List<LocatedBlock> blks,
LocatedBlock lastBlock,
boolean isLastBlockCompleted)
public Constructor
|
Constructor and Description |
---|
LocatedBlocks(long flength,
boolean isUnderConstuction,
List<LocatedBlock> blks,
LocatedBlock lastBlock,
boolean isLastBlockCompleted)
public Constructor
|
Modifier and Type | Method and Description |
---|---|
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.addBlock(String src,
String clientName,
ExtendedBlock previous,
DatanodeInfo[] excludeNodes,
long fileId,
String[] favoredNodes) |
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.append(String src,
String clientName) |
static LocatedBlock |
PBHelper.convert(HdfsProtos.LocatedBlockProto proto) |
static LocatedBlock[] |
PBHelper.convertLocatedBlock(HdfsProtos.LocatedBlockProto[] lb) |
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.getAdditionalDatanode(String src,
ExtendedBlock blk,
DatanodeInfo[] existings,
DatanodeInfo[] excludes,
int numAdditionalNodes,
String clientName) |
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.updateBlockForPipeline(ExtendedBlock block,
String clientName) |
Modifier and Type | Method and Description |
---|---|
static List<LocatedBlock> |
PBHelper.convertLocatedBlock(List<HdfsProtos.LocatedBlockProto> lb) |
Modifier and Type | Method and Description |
---|---|
static HdfsProtos.LocatedBlockProto |
PBHelper.convert(LocatedBlock b) |
static HdfsProtos.LocatedBlockProto[] |
PBHelper.convertLocatedBlock(LocatedBlock[] lb) |
void |
DatanodeProtocolClientSideTranslatorPB.reportBadBlocks(LocatedBlock[] blocks) |
void |
ClientNamenodeProtocolTranslatorPB.reportBadBlocks(LocatedBlock[] blocks) |
Modifier and Type | Method and Description |
---|---|
static List<HdfsProtos.LocatedBlockProto> |
PBHelper.convertLocatedBlock2(List<LocatedBlock> lb) |
Constructor and Description |
---|
ClientDatanodeProtocolTranslatorPB(DatanodeID datanodeid,
Configuration conf,
int socketTimeout,
boolean connectToDnViaHostname,
LocatedBlock locatedBlock) |
Modifier and Type | Method and Description |
---|---|
LocatedBlock |
BlockManager.convertLastBlockToUnderConstruction(MutableBlockCollection bc)
Convert the last block of the file to an under construction block.
|
Modifier and Type | Method and Description |
---|---|
void |
BlockManager.setBlockToken(LocatedBlock b,
BlockTokenSecretManager.AccessMode mode)
Generate a block token for the located block.
|
int |
BlockPlacementPolicyDefault.verifyBlockPlacement(String srcPath,
LocatedBlock lBlk,
int minRacks) |
abstract int |
BlockPlacementPolicy.verifyBlockPlacement(String srcPath,
LocatedBlock lBlk,
int minRacks)
Verify that the block is replicated on at least minRacks different racks
if there is more than minRacks rack in the system.
|
Modifier and Type | Method and Description |
---|---|
void |
DatanodeManager.sortLocatedBlocks(String targethost,
List<LocatedBlock> locatedblocks)
Sort the located blocks by the distance to the target host.
|
Modifier and Type | Method and Description |
---|---|
static DatanodeInfo |
JspHelper.bestNode(LocatedBlock blk,
Configuration conf) |
Modifier and Type | Class and Description |
---|---|
static class |
BlockRecoveryCommand.RecoveringBlock
This is a block with locations from which it should be recovered
and the new generation stamp, which the block will have after
successful recovery.
|
Modifier and Type | Method and Description |
---|---|
void |
DatanodeProtocol.reportBadBlocks(LocatedBlock[] blocks)
|
Copyright © 2013 Apache Software Foundation. All rights reserved.