Uses of Class
org.apache.hadoop.hdfs.server.protocol.DatanodeRegistration
Packages that use DatanodeRegistration
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of DatanodeRegistration in org.apache.hadoop.hdfs.protocolPB
Methods in org.apache.hadoop.hdfs.protocolPB that return DatanodeRegistrationModifier and TypeMethodDescriptionstatic DatanodeRegistrationPBHelper.convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeRegistrationProto proto) DatanodeProtocolClientSideTranslatorPB.registerDatanode(DatanodeRegistration registration) Methods in org.apache.hadoop.hdfs.protocolPB with parameters of type DatanodeRegistrationModifier and TypeMethodDescriptionvoidDatanodeProtocolClientSideTranslatorPB.blockReceivedAndDeleted(DatanodeRegistration registration, String poolId, StorageReceivedDeletedBlocks[] receivedAndDeletedBlocks) DatanodeProtocolClientSideTranslatorPB.blockReport(DatanodeRegistration registration, String poolId, StorageBlockReport[] reports, BlockReportContext context) DatanodeProtocolClientSideTranslatorPB.cacheReport(DatanodeRegistration registration, String poolId, List<Long> blockIds) static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeRegistrationProtoPBHelper.convert(DatanodeRegistration registration) voidDatanodeProtocolClientSideTranslatorPB.errorReport(DatanodeRegistration registration, int errorCode, String msg) DatanodeProtocolClientSideTranslatorPB.registerDatanode(DatanodeRegistration registration) DatanodeProtocolClientSideTranslatorPB.sendHeartbeat(DatanodeRegistration registration, org.apache.hadoop.hdfs.server.protocol.StorageReport[] reports, long cacheCapacity, long cacheUsed, int xmitsInProgress, int xceiverCount, int failedVolumes, VolumeFailureSummary volumeFailureSummary, boolean requestFullBlockReportLease, org.apache.hadoop.hdfs.server.protocol.SlowPeerReports slowPeers, org.apache.hadoop.hdfs.server.protocol.SlowDiskReports slowDisks) voidDatanodeLifelineProtocolClientSideTranslatorPB.sendLifeline(DatanodeRegistration registration, org.apache.hadoop.hdfs.server.protocol.StorageReport[] reports, long cacheCapacity, long cacheUsed, int xmitsInProgress, int xceiverCount, int failedVolumes, VolumeFailureSummary volumeFailureSummary) -
Uses of DatanodeRegistration in org.apache.hadoop.hdfs.server.blockmanagement
Methods in org.apache.hadoop.hdfs.server.blockmanagement with parameters of type DatanodeRegistrationModifier and TypeMethodDescriptionDatanodeManager.handleHeartbeat(DatanodeRegistration nodeReg, org.apache.hadoop.hdfs.server.protocol.StorageReport[] reports, String blockPoolId, long cacheCapacity, long cacheUsed, int xceiverCount, int xmitsInProgress, int failedVolumes, VolumeFailureSummary volumeFailureSummary, org.apache.hadoop.hdfs.server.protocol.SlowPeerReports slowPeers, org.apache.hadoop.hdfs.server.protocol.SlowDiskReports slowDisks) Handle heartbeat from datanodes.voidDatanodeManager.handleLifeline(DatanodeRegistration nodeReg, org.apache.hadoop.hdfs.server.protocol.StorageReport[] reports, long cacheCapacity, long cacheUsed, int xceiverCount, int failedVolumes, VolumeFailureSummary volumeFailureSummary) Handles a lifeline message sent by a DataNode.voidBlockManager.registerDatanode(DatanodeRegistration nodeReg) voidDatanodeManager.registerDatanode(DatanodeRegistration nodeReg) Register the given datanode with the namenode.longBlockManager.requestBlockReportLeaseId(DatanodeRegistration nodeReg) -
Uses of DatanodeRegistration in org.apache.hadoop.hdfs.server.datanode
Methods in org.apache.hadoop.hdfs.server.datanode that return DatanodeRegistrationModifier and TypeMethodDescriptionDataNode.getDNRegistrationForBP(String bpid) get BP registration by blockPool idMethods in org.apache.hadoop.hdfs.server.datanode with parameters of type DatanodeRegistrationModifier and TypeMethodDescriptionvoidBPServiceActorAction.reportTo(DatanodeProtocolClientSideTranslatorPB bpNamenode, DatanodeRegistration bpRegistration) voidErrorReportAction.reportTo(DatanodeProtocolClientSideTranslatorPB bpNamenode, DatanodeRegistration bpRegistration) voidReportBadBlockAction.reportTo(DatanodeProtocolClientSideTranslatorPB bpNamenode, DatanodeRegistration bpRegistration) -
Uses of DatanodeRegistration in org.apache.hadoop.hdfs.server.namenode
Methods in org.apache.hadoop.hdfs.server.namenode that return DatanodeRegistrationModifier and TypeMethodDescriptionNameNodeRpcServer.registerDatanode(DatanodeRegistration nodeReg) Methods in org.apache.hadoop.hdfs.server.namenode with parameters of type DatanodeRegistrationModifier and TypeMethodDescriptionvoidNameNodeRpcServer.blockReceivedAndDeleted(DatanodeRegistration nodeReg, String poolId, StorageReceivedDeletedBlocks[] receivedAndDeletedBlocks) NameNodeRpcServer.blockReport(DatanodeRegistration nodeReg, String poolId, StorageBlockReport[] reports, BlockReportContext context) NameNodeRpcServer.cacheReport(DatanodeRegistration nodeReg, String poolId, List<Long> blockIds) voidNameNodeRpcServer.errorReport(DatanodeRegistration nodeReg, int errorCode, String msg) NameNodeRpcServer.registerDatanode(DatanodeRegistration nodeReg) NameNodeRpcServer.sendHeartbeat(DatanodeRegistration nodeReg, org.apache.hadoop.hdfs.server.protocol.StorageReport[] report, long dnCacheCapacity, long dnCacheUsed, int xmitsInProgress, int xceiverCount, int failedVolumes, VolumeFailureSummary volumeFailureSummary, boolean requestFullBlockReportLease, org.apache.hadoop.hdfs.server.protocol.SlowPeerReports slowPeers, org.apache.hadoop.hdfs.server.protocol.SlowDiskReports slowDisks) voidNameNodeRpcServer.sendLifeline(DatanodeRegistration nodeReg, org.apache.hadoop.hdfs.server.protocol.StorageReport[] report, long dnCacheCapacity, long dnCacheUsed, int xmitsInProgress, int xceiverCount, int failedVolumes, VolumeFailureSummary volumeFailureSummary) -
Uses of DatanodeRegistration in org.apache.hadoop.hdfs.server.protocol
Methods in org.apache.hadoop.hdfs.server.protocol that return DatanodeRegistrationModifier and TypeMethodDescriptionDatanodeProtocol.registerDatanode(DatanodeRegistration registration) Register Datanode.Methods in org.apache.hadoop.hdfs.server.protocol with parameters of type DatanodeRegistrationModifier and TypeMethodDescriptionvoidDatanodeProtocol.blockReceivedAndDeleted(DatanodeRegistration registration, String poolId, StorageReceivedDeletedBlocks[] rcvdAndDeletedBlocks) blockReceivedAndDeleted() allows the DataNode to tell the NameNode about recently-received and -deleted block data.DatanodeProtocol.blockReport(DatanodeRegistration registration, String poolId, StorageBlockReport[] reports, BlockReportContext context) blockReport() tells the NameNode about all the locally-stored blocks.DatanodeProtocol.cacheReport(DatanodeRegistration registration, String poolId, List<Long> blockIds) Communicates the complete list of locally cached blocks to the NameNode.voidDatanodeProtocol.errorReport(DatanodeRegistration registration, int errorCode, String msg) errorReport() tells the NameNode about something that has gone awry.DatanodeProtocol.registerDatanode(DatanodeRegistration registration) Register Datanode.DatanodeProtocol.sendHeartbeat(DatanodeRegistration registration, org.apache.hadoop.hdfs.server.protocol.StorageReport[] reports, long dnCacheCapacity, long dnCacheUsed, int xmitsInProgress, int xceiverCount, int failedVolumes, VolumeFailureSummary volumeFailureSummary, boolean requestFullBlockReportLease, org.apache.hadoop.hdfs.server.protocol.SlowPeerReports slowPeers, org.apache.hadoop.hdfs.server.protocol.SlowDiskReports slowDisks) sendHeartbeat() tells the NameNode that the DataNode is still alive and well.voidDatanodeLifelineProtocol.sendLifeline(DatanodeRegistration registration, org.apache.hadoop.hdfs.server.protocol.StorageReport[] reports, long dnCacheCapacity, long dnCacheUsed, int xmitsInProgress, int xceiverCount, int failedVolumes, VolumeFailureSummary volumeFailureSummary) Constructors in org.apache.hadoop.hdfs.server.protocol with parameters of type DatanodeRegistration