Uses of Class
org.apache.hadoop.hdfs.protocol.LocatedBlock
Packages that use LocatedBlock
Package
Description
Implementations of
AbstractFileSystem for hdfs
over rpc and hdfs over web.This package provides the administrative APIs for HDFS.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of LocatedBlock in org.apache.hadoop.fs
Methods in org.apache.hadoop.fs that return LocatedBlockConstructors in org.apache.hadoop.fs with parameters of type LocatedBlockModifierConstructorDescriptionHdfsBlockLocation(org.apache.hadoop.fs.BlockLocation loc, LocatedBlock block) -
Uses of LocatedBlock in org.apache.hadoop.hdfs
Fields in org.apache.hadoop.hdfs declared as LocatedBlockMethods in org.apache.hadoop.hdfs that return LocatedBlockModifier and TypeMethodDescriptionprotected LocatedBlockDFSInputStream.fetchBlockAt(long offset) Fetch a block from namenode and cache itprotected LocatedBlockDFSInputStream.getBlockAt(long offset) Get block at the specified position.protected LocatedBlockDFSInputStream.refreshLocatedBlock(LocatedBlock block) Refresh cached block locations.protected LocatedBlockDFSStripedInputStream.refreshLocatedBlock(LocatedBlock block) The super methodDFSInputStream.refreshLocatedBlock(org.apache.hadoop.hdfs.protocol.LocatedBlock)refreshes cached LocatedBlock by executingDFSInputStream.getBlockAt(long)again.Methods in org.apache.hadoop.hdfs that return types with arguments of type LocatedBlockModifier and TypeMethodDescriptionDFSInputStream.getAllBlocks()Return collection of blocks that has already been located.Methods in org.apache.hadoop.hdfs with parameters of type LocatedBlockModifier and TypeMethodDescriptionstatic ClientDatanodeProtocolDFSUtilClient.createClientDatanodeProtocolProxy(DatanodeID datanodeid, org.apache.hadoop.conf.Configuration conf, int socketTimeout, boolean connectToDnViaHostname, LocatedBlock locatedBlock) Create aClientDatanodeProtocolproxyprotected voidDFSInputStream.fetchBlockByteRange(LocatedBlock block, long start, long end, ByteBuffer buf, DFSUtilClient.CorruptedBlocks corruptedBlocks, Map<InetSocketAddress, List<IOException>> exceptionMap) protected voidDFSStripedInputStream.fetchBlockByteRange(LocatedBlock block, long start, long end, ByteBuffer buf, DFSUtilClient.CorruptedBlocks corruptedBlocks, Map<InetSocketAddress, List<IOException>> exceptionMap) Real implementation of pread.protected org.apache.hadoop.hdfs.DFSInputStream.DNAddrPairDFSInputStream.getBestNodeDNAddrPair(LocatedBlock block, Collection<DatanodeInfo> ignoredNodes) Get the best node from which to stream the data.protected BlockReaderDFSInputStream.getBlockReader(LocatedBlock targetBlock, long offsetInBlock, long length, InetSocketAddress targetAddr, org.apache.hadoop.fs.StorageType storageType, DatanodeInfo datanode) protected org.apache.hadoop.util.DataChecksum.TypeDFSClient.inferChecksumTypeByReading(LocatedBlock lb, DatanodeInfo dn) Infer the checksum type for a replica by sending an OP_READ_BLOCK for the first byte of that replica.voidDFSClientFaultInjector.onCreateBlockReader(LocatedBlock block, int chunkIndex, long offset, long length) protected LocatedBlockDFSInputStream.refreshLocatedBlock(LocatedBlock block) Refresh cached block locations.protected LocatedBlockDFSStripedInputStream.refreshLocatedBlock(LocatedBlock block) The super methodDFSInputStream.refreshLocatedBlock(org.apache.hadoop.hdfs.protocol.LocatedBlock)refreshes cached LocatedBlock by executingDFSInputStream.getBlockAt(long)again.voidDFSClient.reportBadBlocks(LocatedBlock[] blocks) Report corrupt blocks that were discovered by the client.protected voidDFSInputStream.reportLostBlock(LocatedBlock lostBlock, Collection<DatanodeInfo> ignoredNodes) Warn the user of a lost blockprotected voidDFSStripedInputStream.reportLostBlock(LocatedBlock lostBlock, Collection<DatanodeInfo> ignoredNodes) Method parameters in org.apache.hadoop.hdfs with type arguments of type LocatedBlockModifier and TypeMethodDescriptionstatic org.apache.hadoop.fs.BlockLocation[]DFSUtilClient.locatedBlocks2Locations(List<LocatedBlock> blocks) Convert a List to BlockLocation[]Constructors in org.apache.hadoop.hdfs with parameters of type LocatedBlockModifierConstructorDescriptionCannotObtainBlockLengthException(LocatedBlock locatedBlock) Constructs anCannotObtainBlockLengthExceptionwith the specified LocatedBlock that failed to obtain block length.CannotObtainBlockLengthException(LocatedBlock locatedBlock, String src) Constructs anCannotObtainBlockLengthExceptionwith the specified LocatedBlock and file that failed to obtain block length. -
Uses of LocatedBlock in org.apache.hadoop.hdfs.client
Methods in org.apache.hadoop.hdfs.client that return types with arguments of type LocatedBlockModifier and TypeMethodDescriptionHdfsDataInputStream.getAllBlocks()Get the collection of blocks that has already been located. -
Uses of LocatedBlock in org.apache.hadoop.hdfs.protocol
Subclasses of LocatedBlock in org.apache.hadoop.hdfs.protocolMethods in org.apache.hadoop.hdfs.protocol that return LocatedBlockModifier and TypeMethodDescriptionClientProtocol.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().LocatedBlocks.get(int index) Get located block.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.LastBlockWithStatus.getLastBlock()LocatedBlocks.getLastLocatedBlock()Get the last located block.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.Methods in org.apache.hadoop.hdfs.protocol that return types with arguments of type LocatedBlockMethods in org.apache.hadoop.hdfs.protocol with parameters of type LocatedBlockModifier and TypeMethodDescriptionvoidClientProtocol.reportBadBlocks(LocatedBlock[] blocks) The client wants to report corrupted blocks (blocks with specified locations on datanodes).Method parameters in org.apache.hadoop.hdfs.protocol with type arguments of type LocatedBlockModifier and TypeMethodDescriptionvoidLocatedBlocks.insertRange(int blockIdx, List<LocatedBlock> newBlocks) Constructors in org.apache.hadoop.hdfs.protocol with parameters of type LocatedBlockModifierConstructorDescriptionLastBlockWithStatus(LocatedBlock lastBlock, HdfsFileStatus fileStatus) LocatedBlocks(long flength, boolean isUnderConstuction, List<LocatedBlock> blks, LocatedBlock lastBlock, boolean isLastBlockCompleted, org.apache.hadoop.fs.FileEncryptionInfo feInfo, ErasureCodingPolicy ecPolicy) Constructor parameters in org.apache.hadoop.hdfs.protocol with type arguments of type LocatedBlockModifierConstructorDescriptionLocatedBlocks(long flength, boolean isUnderConstuction, List<LocatedBlock> blks, LocatedBlock lastBlock, boolean isLastBlockCompleted, org.apache.hadoop.fs.FileEncryptionInfo feInfo, ErasureCodingPolicy ecPolicy) -
Uses of LocatedBlock in org.apache.hadoop.hdfs.protocolPB
Methods in org.apache.hadoop.hdfs.protocolPB that return LocatedBlockModifier and TypeMethodDescriptionClientNamenodeProtocolTranslatorPB.addBlock(String src, String clientName, ExtendedBlock previous, DatanodeInfo[] excludeNodes, long fileId, String[] favoredNodes, EnumSet<AddBlockFlag> addBlockFlags) static LocatedBlock[]PBHelperClient.convertLocatedBlock(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] lb) static LocatedBlockPBHelperClient.convertLocatedBlockProto(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto proto) static LocatedBlock[]PBHelperClient.convertLocatedBlocks(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] lb) ClientNamenodeProtocolTranslatorPB.getAdditionalDatanode(String src, long fileId, ExtendedBlock blk, DatanodeInfo[] existings, String[] existingStorageIDs, DatanodeInfo[] excludes, int numAdditionalNodes, String clientName) ClientNamenodeProtocolTranslatorPB.updateBlockForPipeline(ExtendedBlock block, String clientName) Methods in org.apache.hadoop.hdfs.protocolPB that return types with arguments of type LocatedBlockModifier and TypeMethodDescriptionstatic List<LocatedBlock>PBHelperClient.convertLocatedBlock(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> lb) static List<LocatedBlock>PBHelperClient.convertLocatedBlocks(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> lb) Methods in org.apache.hadoop.hdfs.protocolPB with parameters of type LocatedBlockModifier and TypeMethodDescriptionstatic org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProtoPBHelperClient.convertLocatedBlock(LocatedBlock b) static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[]PBHelperClient.convertLocatedBlocks(LocatedBlock[] lb) voidClientNamenodeProtocolTranslatorPB.reportBadBlocks(LocatedBlock[] blocks) Method parameters in org.apache.hadoop.hdfs.protocolPB with type arguments of type LocatedBlockModifier and TypeMethodDescriptionstatic List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto>PBHelperClient.convertLocatedBlocks2(List<LocatedBlock> lb) Constructors in org.apache.hadoop.hdfs.protocolPB with parameters of type LocatedBlockModifierConstructorDescriptionClientDatanodeProtocolTranslatorPB(DatanodeID datanodeid, org.apache.hadoop.conf.Configuration conf, int socketTimeout, boolean connectToDnViaHostname, LocatedBlock locatedBlock) -
Uses of LocatedBlock in org.apache.hadoop.hdfs.util
Methods in org.apache.hadoop.hdfs.util that return LocatedBlockModifier and TypeMethodDescriptionstatic LocatedBlockStripedBlockUtil.constructInternalBlock(LocatedStripedBlock bg, int idxInReturnedLocs, int cellSize, int dataBlkNum, int idxInBlockGroup) This method creates an internal block at the given index of a block group.static LocatedBlock[]StripedBlockUtil.parseStripedBlockGroup(LocatedStripedBlock bg, int cellSize, int dataBlkNum, int parityBlkNum) This method parses a striped block group into individual blocks.