Uses of Class
org.apache.hadoop.hdfs.server.protocol.DatanodeCommand
Packages that use DatanodeCommand
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of DatanodeCommand in org.apache.hadoop.hdfs.protocolPB
Methods in org.apache.hadoop.hdfs.protocolPB that return DatanodeCommandModifier and TypeMethodDescriptionDatanodeProtocolClientSideTranslatorPB.blockReport(DatanodeRegistration registration, String poolId, StorageBlockReport[] reports, BlockReportContext context) DatanodeProtocolClientSideTranslatorPB.cacheReport(DatanodeRegistration registration, String poolId, List<Long> blockIds) static DatanodeCommandPBHelper.convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeCommandProto proto) Methods in org.apache.hadoop.hdfs.protocolPB with parameters of type DatanodeCommandModifier and TypeMethodDescriptionstatic org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeCommandProtoPBHelper.convert(DatanodeCommand datanodeCommand) -
Uses of DatanodeCommand in org.apache.hadoop.hdfs.server.blockmanagement
Methods in org.apache.hadoop.hdfs.server.blockmanagement that return DatanodeCommandModifier 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. -
Uses of DatanodeCommand in org.apache.hadoop.hdfs.server.namenode
Methods in org.apache.hadoop.hdfs.server.namenode that return DatanodeCommandModifier and TypeMethodDescriptionNameNodeRpcServer.blockReport(DatanodeRegistration nodeReg, String poolId, StorageBlockReport[] reports, BlockReportContext context) NameNodeRpcServer.cacheReport(DatanodeRegistration nodeReg, String poolId, List<Long> blockIds) -
Uses of DatanodeCommand in org.apache.hadoop.hdfs.server.protocol
Subclasses of DatanodeCommand in org.apache.hadoop.hdfs.server.protocolModifier and TypeClassDescriptionclassBalancer bandwidth command instructs each datanode to change its value for the max amount of network bandwidth it may use during the block balancing operation.classA BlockCommand is an instruction to a datanode regarding some blocks under its control.classA BlockECReconstructionCommand is an instruction to a DataNode to reconstruct a striped block group with missing blocks.classA BlockIdCommand is an instruction to a datanode regarding some blocks under its control.classBlockRecoveryCommand is an instruction to a data-node to recover the specified blocks.classA BlockStorageMovementCommand is an instruction to a DataNode to move the given set of blocks to specified target DataNodes to fulfill the block storage policy.classA DropSPSWorkCommand is an instruction to a datanode to drop the SPSWorker's pending block storage movement queues.classA BlockCommand is an instruction to a datanode to register with the namenode.classclassA RegisterCommand is an instruction to a datanode to register with the namenode.Fields in org.apache.hadoop.hdfs.server.protocol declared as DatanodeCommandMethods in org.apache.hadoop.hdfs.server.protocol that return DatanodeCommandModifier and TypeMethodDescriptionDatanodeProtocol.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.HeartbeatResponse.getCommands()Constructors in org.apache.hadoop.hdfs.server.protocol with parameters of type DatanodeCommandModifierConstructorDescriptionHeartbeatResponse(DatanodeCommand[] cmds, NNHAStatusHeartbeat haStatus, org.apache.hadoop.hdfs.protocol.RollingUpgradeStatus rollingUpdateStatus, long fullBlockReportLeaseId) HeartbeatResponse(DatanodeCommand[] cmds, NNHAStatusHeartbeat haStatus, org.apache.hadoop.hdfs.protocol.RollingUpgradeStatus rollingUpdateStatus, long fullBlockReportLeaseId, boolean isSlownode)