handleHeartbeat(DatanodeRegistration, StorageReport[], String, long, long, int, int, int, VolumeFailureSummary, SlowPeerReports, SlowDiskReports) |  | 0% |  | 0% | 28 | 28 | 77 | 77 | 1 | 1 |
DatanodeManager(BlockManager, Namesystem, Configuration) |  | 0% |  | 0% | 9 | 9 | 72 | 72 | 1 | 1 |
registerDatanode(DatanodeRegistration) |  | 0% |  | 0% | 19 | 19 | 92 | 92 | 1 | 1 |
getBlockRecoveryCommand(String, DatanodeDescriptor) |  | 0% |  | 0% | 19 | 19 | 48 | 48 | 1 | 1 |
getDatanodeListForReport(HdfsConstants.DatanodeReportType) |  | 0% |  | 0% | 29 | 29 | 39 | 39 | 1 | 1 |
sortLocatedBlock(LocatedBlock, String, Comparator) |  | 0% |  | 0% | 10 | 10 | 31 | 31 | 1 | 1 |
getDatanodeStorageInfos(DatanodeID[], String[], String, Object[]) |  | 0% |  | 0% | 8 | 8 | 18 | 18 | 1 | 1 |
sortLocatedStripedBlock(LocatedBlock, Comparator) |  | 0% |  | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
getDatanodeDescriptor(String) |  | 0% |  | 0% | 9 | 9 | 24 | 24 | 1 | 1 |
refreshDatanodes() |  | 0% |  | 0% | 5 | 5 | 17 | 17 | 1 | 1 |
parseDNFromHostsEntry(String) |  | 0% |  | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
getStaleIntervalFromConf(Configuration, long) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
countSoftwareVersions() |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
fetchDatanodes(List, List, boolean) |  | 0% |  | 0% | 10 | 10 | 17 | 17 | 1 | 1 |
addCacheCommands(String, DatanodeDescriptor, List) |  | 0% |  | 0% | 6 | 6 | 17 | 17 | 1 | 1 |
markAllDatanodesStaleAndSetKeyUpdateIfNeed() |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
sortLocatedBlocks(String, List) |  | 0% |  | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
addDatanode(DatanodeDescriptor) |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
resolveNetworkLocation(DatanodeID) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
removeDatanode(DatanodeDescriptor, boolean) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
wipeDatanode(DatanodeID) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
checkIfClusterIsNowMultiRack(DatanodeDescriptor) |  | 0% |  | 0% | 6 | 6 | 12 | 12 | 1 | 1 |
getDnDescriptorsFromIpAddr(List) |  | 0% |  | 0% | 5 | 5 | 11 | 11 | 1 | 1 |
getDatanodeStorageReport(HdfsConstants.DatanodeReportType) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
decrementVersionCount(String) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
getCacheCommand(DatanodeDescriptor.CachedBlocksList, int, String) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
datanodeDump(PrintWriter) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
setBlockInvalidateLimit(int) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
incrementVersionCount(String) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
getDatanode(DatanodeID) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
getNetworkDependencies(DatanodeInfo) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
getNumLiveDataNodes() |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
handleLifeline(DatanodeRegistration, StorageReport[], long, long, int, int, VolumeFailureSummary) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
clearPendingCachingCommands() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
startAdminOperationIfNecessary(DatanodeDescriptor) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
initSlowPeerTracker(Configuration, Timer, boolean) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
removeDatanode(DatanodeID) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
stopSlowPeerCollector() |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
removeDeadDatanode(DatanodeID, boolean) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
setBalancerBandwidth(long) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
resetLastCachingDirectiveSentTime() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
startSlowPeerCollector() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
createSecondaryNodeSorter() |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
clearPendingQueues() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
setHeartbeatInterval(long, int) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getSlowPeersUuidSet() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
restartSlowPeerCollector(long) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
shouldAvoidStaleDataNodesForWrite() |  | 0% |  | 0% | 4 | 4 | 2 | 2 | 1 | 1 |
isInactive(DatanodeInfo) |  | 0% |  | 0% | 6 | 6 | 4 | 4 | 1 | 1 |
getAllSlowDataNodes() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
removeDecomNodeFromList(List) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
refreshNodes(Configuration) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
isNameResolved(InetAddress) |  | 0% |  | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
getDatanodes() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getDatanode(String) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$createSecondaryNodeSorter$0(StorageType, StorageType) |  | 0% |  | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
resolveNetworkLocationWithFallBackToDefaultLocation(DatanodeID) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
getNetworkDependenciesWithDefault(DatanodeInfo) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
resolveUpgradeDomain(DatanodeDescriptor) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
refreshHostsReader(Configuration) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
isDatanodeDead(DatanodeDescriptor) |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getDatanodesSoftwareVersions() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
isSlowNode(String) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
shouldCountVersion(DatanodeDescriptor) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
getNumOfDataNodes() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMaxSlowPeersToReport(int) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
close() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getSlowPeersReport() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getSlowDisksReport() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
activate(Configuration) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
setDatanodeDead(DatanodeDescriptor) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isSlowPeerCollectorInitialized() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
getDatanodeByXferAddr(String, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setHeartbeatInterval(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setHeartbeatRecheckInterval(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getBlockInvalidateLimitFromHBInterval() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getSlowPeersUuidSet$3(Set, DatanodeDescriptor) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDatanodeByHost(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDatanodeByHostName(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
removeDatanode(DatanodeDescriptor) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
resolveNetworkLocation(List) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumDeadDataNodes() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
newFSClusterStats() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getBlockInvalidateLimit(int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
addSlowPeers(String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setHeartbeatExpireInterval(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setAvoidSlowDataNodesForReadEnabled(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMaxSlowpeerCollectNodes(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getDecommissioningNodes() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getEnteringMaintenanceNodes() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHeartbeatRecheckInterval() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setNumStaleNodes(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setNumStaleStorages(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setShouldSendCachingCommands(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$createSecondaryNodeSorter$2(Comparator, List) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createSecondaryNodeSorter$1(Comparator, List) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNetworkTopology() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHeartbeatManager() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDatanodeAdminManager() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHostConfigManager() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFSClusterStats() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getBlockInvalidateLimit() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDatanodeStatistics() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getEnableAvoidSlowDataNodesForRead() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxSlowpeerCollectNodes() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHost2DatanodeMap() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getBlocksPerPostponedMisreplicatedBlocksRescan() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getStaleInterval() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHeartbeatInterval() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumStaleNodes() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumStaleStorages() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSlowPeerTracker() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSlowDiskTracker() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDatanodeMap() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSlowPeerCollectionInterval() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSlowNodesUuidSet() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |