Uses of Class
org.apache.hadoop.hdfs.protocol.ExtendedBlock

Packages that use ExtendedBlock

Package	Description
org.apache.hadoop.hdfs
org.apache.hadoop.hdfs.client	This package provides the administrative APIs for HDFS.
org.apache.hadoop.hdfs.client.impl	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.hadoop.hdfs.protocol	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.hadoop.hdfs.protocol.datatransfer
org.apache.hadoop.hdfs.protocolPB
org.apache.hadoop.hdfs.server.datanode
org.apache.hadoop.hdfs.util	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

Uses of ExtendedBlock in org.apache.hadoop.hdfs

Methods in org.apache.hadoop.hdfs that return ExtendedBlock

Modifier and Type	Method	Description
ExtendedBlock	DFSInputStream.getCurrentBlock()	Returns the block containing the target position.

Methods in org.apache.hadoop.hdfs that return types with arguments of type ExtendedBlock

Modifier and Type	Method	Description
Map<ExtendedBlock,Set<DatanodeInfo>>	DFSUtilClient.CorruptedBlocks.getCorruptionMap()

Methods in org.apache.hadoop.hdfs with parameters of type ExtendedBlock

Modifier and Type	Method	Description
void	DFSUtilClient.CorruptedBlocks.addCorruptedBlock(ExtendedBlock blk, DatanodeInfo node)	Indicate a block replica on the specified datanode is corrupted
protected void	DFSOutputStream.completeFile(ExtendedBlock last)
static ExtendedBlockId	ExtendedBlockId.fromExtendedBlock(ExtendedBlock block)

Uses of ExtendedBlock in org.apache.hadoop.hdfs.client

Methods in org.apache.hadoop.hdfs.client that return ExtendedBlock

Modifier and Type	Method	Description
ExtendedBlock	HdfsDataInputStream.getCurrentBlock()	Get the block containing the target position.

Uses of ExtendedBlock in org.apache.hadoop.hdfs.client.impl

Methods in org.apache.hadoop.hdfs.client.impl with parameters of type ExtendedBlock

Modifier and Type	Method	Description
static BlockReader	BlockReaderRemote.newBlockReader(String file, ExtendedBlock block, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, long startOffset, long len, boolean verifyChecksum, String clientName, Peer peer, DatanodeID datanodeID, PeerCache peerCache, CachingStrategy cachingStrategy, int networkDistance, org.apache.hadoop.conf.Configuration configuration)	Create a new BlockReader specifically to satisfy a read.
BlockReaderFactory	BlockReaderFactory.setBlock(ExtendedBlock block)

Uses of ExtendedBlock in org.apache.hadoop.hdfs.protocol

Methods in org.apache.hadoop.hdfs.protocol that return ExtendedBlock

Modifier and Type	Method	Description
ExtendedBlock	BlockLocalPathInfo.getBlock()
ExtendedBlock	LocatedBlock.getBlock()
ExtendedBlock	StripedBlockInfo.getBlock()

Methods in org.apache.hadoop.hdfs.protocol with parameters of type ExtendedBlock

Modifier and Type	Method	Description
void	ClientProtocol.abandonBlock(ExtendedBlock b, long fileId, String src, String holder)	The client can give up on a block by calling abandonBlock().
LocatedBlock	ClientProtocol.addBlock(String src, String clientName, ExtendedBlock previous, DatanodeInfo[] excludeNodes, long fileId, String[] favoredNodes, EnumSet<AddBlockFlag> addBlockFlags)	A client that wants to write an additional block to the indicated filename (which must currently be open for writing) should call addBlock().
boolean	ClientProtocol.complete(String src, String clientName, ExtendedBlock last, long fileId)	The client is done writing data to the given filename, and would like to complete it.
LocatedBlock	ClientProtocol.getAdditionalDatanode(String src, long fileId, ExtendedBlock blk, DatanodeInfo[] existings, String[] existingStorageIDs, DatanodeInfo[] excludes, int numAdditionalNodes, String clientName)	Get a datanode for an existing pipeline.
BlockLocalPathInfo	ClientDatanodeProtocol.getBlockLocalPathInfo(ExtendedBlock block, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> token)	Retrieves the path names of the block file and metadata file stored on the local file system.
static Block	ExtendedBlock.getLocalBlock(ExtendedBlock b)
long	ClientDatanodeProtocol.getReplicaVisibleLength(ExtendedBlock b)	Return the visible length of a replica.
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.
void	ClientProtocol.updatePipeline(String clientName, ExtendedBlock oldBlock, ExtendedBlock newBlock, DatanodeID[] newNodes, String[] newStorageIDs)	Update a pipeline for a block under construction.

Constructors in org.apache.hadoop.hdfs.protocol with parameters of type ExtendedBlock

Modifier	Constructor	Description
	BlockLocalPathInfo(ExtendedBlock b, String file, String metafile)	Constructs BlockLocalPathInfo.
	ExtendedBlock(ExtendedBlock b)
	LocatedBlock(ExtendedBlock b, DatanodeInfo[] locs)
	LocatedBlock(ExtendedBlock b, DatanodeInfo[] locs, String[] storageIDs, org.apache.hadoop.fs.StorageType[] storageTypes)
	LocatedBlock(ExtendedBlock b, DatanodeInfo[] locs, String[] storageIDs, org.apache.hadoop.fs.StorageType[] storageTypes, long startOffset, boolean corrupt, DatanodeInfo[] cachedLocs)
	LocatedBlock(ExtendedBlock b, DatanodeInfoWithStorage[] locs, String[] storageIDs, org.apache.hadoop.fs.StorageType[] storageTypes, long startOffset, boolean corrupt, DatanodeInfo[] cachedLocs)
	LocatedStripedBlock(ExtendedBlock b, DatanodeInfo[] locs, String[] storageIDs, org.apache.hadoop.fs.StorageType[] storageTypes, byte[] indices, long startOffset, boolean corrupt, DatanodeInfo[] cachedLocs)
	StripedBlockInfo(ExtendedBlock block, DatanodeInfo[] datanodes, org.apache.hadoop.security.token.Token<BlockTokenIdentifier>[] blockTokens, byte[] blockIndices, ErasureCodingPolicy ecPolicy)

Uses of ExtendedBlock in org.apache.hadoop.hdfs.protocol.datatransfer

Methods in org.apache.hadoop.hdfs.protocol.datatransfer with parameters of type ExtendedBlock

Modifier and Type	Method	Description
void	DataTransferProtocol.blockChecksum(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, BlockChecksumOptions blockChecksumOptions)	Get block checksum (MD5 of CRC32).
void	Sender.blockChecksum(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, BlockChecksumOptions blockChecksumOptions)
void	DataTransferProtocol.copyBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken)	Copy a block.
void	Sender.copyBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken)
void	DataTransferProtocol.readBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, long blockOffset, long length, boolean sendChecksum, CachingStrategy cachingStrategy)	Read a block.
void	Sender.readBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, long blockOffset, long length, boolean sendChecksum, CachingStrategy cachingStrategy)
void	DataTransferProtocol.replaceBlock(ExtendedBlock blk, org.apache.hadoop.fs.StorageType storageType, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String delHint, DatanodeInfo source, String storageId)	Receive a block from a source datanode and then notifies the namenode to remove the copy from the original datanode.
void	Sender.replaceBlock(ExtendedBlock blk, org.apache.hadoop.fs.StorageType storageType, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String delHint, DatanodeInfo source, String storageId)
void	DataTransferProtocol.requestShortCircuitFds(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, ShortCircuitShm.SlotId slotId, int maxVersion, boolean supportsReceiptVerification)	Request short circuit access file descriptors from a DataNode.
void	Sender.requestShortCircuitFds(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, ShortCircuitShm.SlotId slotId, int maxVersion, boolean supportsReceiptVerification)
void	DataTransferProtocol.transferBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, DatanodeInfo[] targets, org.apache.hadoop.fs.StorageType[] targetStorageTypes, String[] targetStorageIDs)	Transfer a block to another datanode.
void	Sender.transferBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, DatanodeInfo[] targets, org.apache.hadoop.fs.StorageType[] targetStorageTypes, String[] targetStorageIds)
void	DataTransferProtocol.writeBlock(ExtendedBlock blk, org.apache.hadoop.fs.StorageType storageType, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, DatanodeInfo[] targets, org.apache.hadoop.fs.StorageType[] targetStorageTypes, DatanodeInfo source, BlockConstructionStage stage, int pipelineSize, long minBytesRcvd, long maxBytesRcvd, long latestGenerationStamp, org.apache.hadoop.util.DataChecksum requestedChecksum, CachingStrategy cachingStrategy, boolean allowLazyPersist, boolean pinning, boolean[] targetPinnings, String storageID, String[] targetStorageIDs)	Write a block to a datanode pipeline.
void	Sender.writeBlock(ExtendedBlock blk, org.apache.hadoop.fs.StorageType storageType, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, DatanodeInfo[] targets, org.apache.hadoop.fs.StorageType[] targetStorageTypes, DatanodeInfo source, BlockConstructionStage stage, int pipelineSize, long minBytesRcvd, long maxBytesRcvd, long latestGenerationStamp, org.apache.hadoop.util.DataChecksum requestedChecksum, CachingStrategy cachingStrategy, boolean allowLazyPersist, boolean pinning, boolean[] targetPinnings, String storageId, String[] targetStorageIds)

Uses of ExtendedBlock in org.apache.hadoop.hdfs.protocolPB

Methods in org.apache.hadoop.hdfs.protocolPB that return ExtendedBlock

Modifier and Type	Method	Description
static ExtendedBlock	PBHelperClient.convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ExtendedBlockProto eb)

Methods in org.apache.hadoop.hdfs.protocolPB with parameters of type ExtendedBlock

Modifier and Type	Method	Description
void	ClientNamenodeProtocolTranslatorPB.abandonBlock(ExtendedBlock b, long fileId, String src, String holder)
LocatedBlock	ClientNamenodeProtocolTranslatorPB.addBlock(String src, String clientName, ExtendedBlock previous, DatanodeInfo[] excludeNodes, long fileId, String[] favoredNodes, EnumSet<AddBlockFlag> addBlockFlags)
boolean	ClientNamenodeProtocolTranslatorPB.complete(String src, String clientName, ExtendedBlock last, long fileId)
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ExtendedBlockProto	PBHelperClient.convert(ExtendedBlock b)
LocatedBlock	ClientNamenodeProtocolTranslatorPB.getAdditionalDatanode(String src, long fileId, ExtendedBlock blk, DatanodeInfo[] existings, String[] existingStorageIDs, DatanodeInfo[] excludes, int numAdditionalNodes, String clientName)
BlockLocalPathInfo	ClientDatanodeProtocolTranslatorPB.getBlockLocalPathInfo(ExtendedBlock block, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> token)
long	ClientDatanodeProtocolTranslatorPB.getReplicaVisibleLength(ExtendedBlock b)
LocatedBlock	ClientNamenodeProtocolTranslatorPB.updateBlockForPipeline(ExtendedBlock block, String clientName)
void	ClientNamenodeProtocolTranslatorPB.updatePipeline(String clientName, ExtendedBlock oldBlock, ExtendedBlock newBlock, DatanodeID[] newNodes, String[] storageIDs)

Uses of ExtendedBlock in org.apache.hadoop.hdfs.server.datanode

Constructors in org.apache.hadoop.hdfs.server.datanode with parameters of type ExtendedBlock

Modifier	Constructor	Description
	ReplicaNotFoundException(ExtendedBlock b)

Uses of ExtendedBlock in org.apache.hadoop.hdfs.util

Methods in org.apache.hadoop.hdfs.util that return ExtendedBlock

Modifier and Type	Method	Description
static ExtendedBlock	StripedBlockUtil.constructInternalBlock(ExtendedBlock blockGroup, int cellSize, int dataBlkNum, int idxInBlockGroup)	This method creates an internal ExtendedBlock at the given index of a block group.
static ExtendedBlock	StripedBlockUtil.constructInternalBlock(ExtendedBlock blockGroup, ErasureCodingPolicy ecPolicy, int idxInBlockGroup)

Methods in org.apache.hadoop.hdfs.util with parameters of type ExtendedBlock

Modifier and Type	Method	Description
static void	StripedBlockUtil.checkBlocks(ExtendedBlock blockGroup, int i, ExtendedBlock blocki)	Check if the information such as IDs and generation stamps in block-i match the block group.
static ExtendedBlock	StripedBlockUtil.constructInternalBlock(ExtendedBlock blockGroup, int cellSize, int dataBlkNum, int idxInBlockGroup)	This method creates an internal ExtendedBlock at the given index of a block group.
static ExtendedBlock	StripedBlockUtil.constructInternalBlock(ExtendedBlock blockGroup, ErasureCodingPolicy ecPolicy, int idxInBlockGroup)