Uses of Class
org.apache.hadoop.hdfs.server.blockmanagement.BlockInfo
Packages that use BlockInfo
Package
Description
-
Uses of BlockInfo in org.apache.hadoop.hdfs.server.blockmanagement
Subclasses of BlockInfo in org.apache.hadoop.hdfs.server.blockmanagementModifier and TypeClassDescriptionclassSubclass ofBlockInfo, used for a block with replication scheme.classSubclass ofBlockInfo, presenting a block group in erasure coding.Fields in org.apache.hadoop.hdfs.server.blockmanagement declared as BlockInfoMethods in org.apache.hadoop.hdfs.server.blockmanagement that return BlockInfoModifier and TypeMethodDescriptionBlockManager.addBlockCollection(BlockInfo block, BlockCollection bc) BlockManager.addBlockCollectionWithCheck(BlockInfo block, BlockCollection bc) Do some check when adding a block to blocksmap.BlockCollection.getBlocks()Get the blocks (striped or contiguous).BlockCollection.getLastBlock()Get the last block of the collection.DatanodeDescriptor.getLeaseRecoveryCommand(int maxTransfers) BlockManager.getStoredBlock(org.apache.hadoop.hdfs.protocol.Block block) BlockUnderConstructionFeature.getTruncateBlock()Get recover blockBlockInfo.moveBlockToHead(BlockInfo head, DatanodeStorageInfo storage, int curIndex, int headIndex) Remove this block from the list of blocks related to the specified DatanodeDescriptor.Methods in org.apache.hadoop.hdfs.server.blockmanagement that return types with arguments of type BlockInfoModifier and TypeMethodDescriptionBlockManager.getCorruptReplicaBlockIterator()Return an iterator over the set of blocks for which there are no replicas.BlockManager.getMarkedDeleteQueue()Methods in org.apache.hadoop.hdfs.server.blockmanagement with parameters of type BlockInfoModifier and TypeMethodDescriptionorg.apache.hadoop.hdfs.server.blockmanagement.DatanodeStorageInfo.AddBlockResultBlockManager.addBlockCollection(BlockInfo block, BlockCollection bc) BlockManager.addBlockCollectionWithCheck(BlockInfo block, BlockCollection bc) Do some check when adding a block to blocksmap.booleanBlockManager.addBlockRecoveryAttempt(BlockInfo b) Checks whether a recovery attempt has been made for the given block.voidBlockManager.addExpectedReplicasToPending(BlockInfo blk) If IBR is not sent from expected locations yet, add the datanodes to pendingReconstruction in order to keep RedundancyMonitor from scheduling the block.voidBlockCollection.convertLastBlockToUC(BlockInfo lastBlock, DatanodeStorageInfo[] targets) Convert the last block of the collection to an under-construction block and set the locations.BlockManager.countNodes(BlockInfo b) Return the number of nodes hosting a given block, grouped by the state of those replicas.org.apache.hadoop.hdfs.protocol.LocatedBlocksBlockManager.createLocatedBlocks(BlockInfo[] blocks, long fileSizeExcludeBlocksUnderConstruction, boolean isFileUnderConstruction, long offset, long length, boolean needBlockToken, boolean inSnapshot, org.apache.hadoop.fs.FileEncryptionInfo feInfo, org.apache.hadoop.hdfs.protocol.ErasureCodingPolicy ecPolicy) Create a LocatedBlocks.voidBlockManager.forceCompleteBlock(BlockInfo block) Force the given block in the given file to be marked as complete, regardless of whether enough replicas are present.intBlockManager.getDefaultStorageNum(BlockInfo block) shortBlockManager.getExpectedLiveRedundancyNum(BlockInfo block, NumberReplicas numberReplicas) shortBlockManager.getExpectedRedundancyNum(BlockInfo block) shortBlockManager.getMinStorageNum(BlockInfo block) BlockManager.getStorages(BlockInfo block) booleanBlockManager.hasMinStorage(BlockInfo block) booleanBlockManager.hasMinStorage(BlockInfo block, int liveNum) voidBlockUnderConstructionFeature.initializeBlockRecovery(BlockInfo blockInfo, long recoveryId, boolean startRecovery) Initialize lease recovery for this block.voidDatanodeStorageInfo.insertToList(BlockInfo b) booleanBlockManager.isExcess(DatanodeDescriptor dn, BlockInfo blk) protected booleanDatanodeAdminManager.isSufficient(BlockInfo block, BlockCollection bc, NumberReplicas numberReplicas, boolean isDecommission, boolean isMaintenance) Checks whether a block is sufficiently replicated/stored for DECOMMISSION_INPROGRESS or ENTERING_MAINTENANCE datanodes.booleanBlockManager.isSufficientlyReplicated(BlockInfo b) Check if a block is replicated to at least the minimum replication.protected voidDatanodeAdminManager.logBlockReplicationInfo(BlockInfo block, BlockCollection bc, DatanodeDescriptor srcNode, NumberReplicas num, Iterable<DatanodeStorageInfo> storages) voidBlockManager.markBlockReplicasAsCorrupt(org.apache.hadoop.hdfs.protocol.Block oldBlock, BlockInfo block, long oldGenerationStamp, long oldNumBytes, DatanodeStorageInfo[] newStorages) Mark block replicas as corrupt except those on the storages in newStorages list.BlockInfo.moveBlockToHead(BlockInfo head, DatanodeStorageInfo storage, int curIndex, int headIndex) Remove this block from the list of blocks related to the specified DatanodeDescriptor.static org.apache.hadoop.hdfs.protocol.LocatedBlockBlockManager.newLocatedBlock(org.apache.hadoop.hdfs.protocol.ExtendedBlock eb, BlockInfo info, DatanodeStorageInfo[] locs, long offset) voidBlockManager.removeBlock(BlockInfo block) voidBlockManager.removeBlockFromMap(BlockInfo block) voidBlockManager.removeStoredBlock(BlockInfo storedBlock, DatanodeDescriptor node) Modify (block-->datanode) map.voidSet the block (contiguous or striped) at the given index.voidBlockManager.setReplication(short oldRepl, short newRepl, BlockInfo b) Set replication for the blocks.voidBlockUnderConstructionFeature.setTruncateBlock(BlockInfo recoveryBlock) voidBlockManager.successfulBlockRecovery(BlockInfo block) Notification of a successful block recovery.voidBlockManager.updateLastBlock(BlockInfo lastBlock, org.apache.hadoop.hdfs.protocol.ExtendedBlock newBlock) Method parameters in org.apache.hadoop.hdfs.server.blockmanagement with type arguments of type BlockInfoModifier and TypeMethodDescriptionvoidBlockManager.addBLocksToMarkedDeleteQueue(List<BlockInfo> blockInfos) intBlockManager.processMisReplicatedBlocks(List<BlockInfo> blocks) Schedule replication work for a specified list of mis-replicated blocks and return total number of blocks scheduled for replication. -
Uses of BlockInfo in org.apache.hadoop.hdfs.server.namenode
Methods in org.apache.hadoop.hdfs.server.namenode that return BlockInfoModifier and TypeMethodDescriptionINode.BlocksMapUpdateInfo.UpdatedReplicationInfo.block()INodeFile.getBlocks()INodeFile.getBlocks(int snapshot) INodeFile.getLastBlock()Methods in org.apache.hadoop.hdfs.server.namenode that return types with arguments of type BlockInfoMethods in org.apache.hadoop.hdfs.server.namenode with parameters of type BlockInfoModifier and TypeMethodDescriptionvoidINode.BlocksMapUpdateInfo.addDeleteBlock(BlockInfo toDelete) Add a to-be-deleted block into theINode.BlocksMapUpdateInfo.toDeleteListvoidINode.BlocksMapUpdateInfo.addUpdateReplicationFactor(BlockInfo block, short targetRepl) voidINodeFile.collectBlocksBeyondSnapshot(BlockInfo[] snapshotBlocks, INode.BlocksMapUpdateInfo collectedBlocks) This function is only called when block list is stored in snapshot diffs.voidINodeFile.convertLastBlockToUC(BlockInfo lastBlock, DatanodeStorageInfo[] locations) voidvoidFSDirectory.updateSpaceForCompleteBlock(BlockInfo completeBlk, INodesInPath inodes) Update the cached quota space for a block that is being completed.Method parameters in org.apache.hadoop.hdfs.server.namenode with type arguments of type BlockInfoModifier and TypeMethodDescriptionlongINodeFile.collectBlocksBeyondMax(long max, INode.BlocksMapUpdateInfo collectedBlocks, Set<BlockInfo> toRetain) Remove full blocks at the end file up to newLengthConstructors in org.apache.hadoop.hdfs.server.namenode with parameters of type BlockInfoModifierConstructorDescriptionINodeFile(long id, byte[] name, org.apache.hadoop.fs.permission.PermissionStatus permissions, long mtime, long atime, BlockInfo[] blklist, short replication, long preferredBlockSize) UpdatedReplicationInfo(short targetReplication, BlockInfo block) -
Uses of BlockInfo in org.apache.hadoop.hdfs.server.namenode.snapshot
Methods in org.apache.hadoop.hdfs.server.namenode.snapshot that return BlockInfoModifier and TypeMethodDescriptionFileDiffList.findEarlierSnapshotBlocks(int snapshotId) FileDiffList.findLaterSnapshotBlocks(int snapshotId) FileDiff.getBlocks()Methods in org.apache.hadoop.hdfs.server.namenode.snapshot with parameters of type BlockInfo