CloudTabletRebalancer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,226 of 4,45450%252 of 44743%1922984939622974
checkInflightWarmUpCacheAsync()2907821%28412%1617506601
migrateTablets(Long, Long)2050%180%1010545411
handleWarmupCompletion(CloudTabletRebalancer.InfightTask, String, boolean, long, List)1530%210%1212333311
checkDecommissionState(Map)1485326%14836%812364701
lambda$batchUpdateCloudReplicaInfoEditlogs$14(String, List, Long, List)1470%40%33323211
balanceImpl(List, String, Map, CloudTabletRebalancer.BalanceType, List)1237337%22826%1416274301
preheatAndUpdateTablet(Tablet, long, long, String, CloudTabletRebalancer.BalanceType, Map)990%40%33191911
sendPreHeatingRpc(List, long, long)920%40%33232311
sendCheckWarmUpCacheAsyncRpc(List, long)910%40%33222211
sendWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)770%80%55161611
updateBeToTablets(Tablet, long, long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)620%n/a119911
updateClusterToBeMap(Tablet, long, String, List)600%60%44171711
batchUpdateCloudReplicaInfoEditlogs(List, CloudTabletRebalancer.StatType)575649%5550%46132701
transferTablet(Tablet, long, long, String, CloudTabletRebalancer.BalanceType, List)410%n/a116611
checkGlobalBalanceConflict(long, long, CloudReplica, ConcurrentHashMap, ConcurrentHashMap)380%40%337711
isConflict(long, long, CloudReplica, CloudTabletRebalancer.BalanceType, ConcurrentHashMap, ConcurrentHashMap)370%80%558811
getTabletSizeInParts(long, CloudReplica, ConcurrentHashMap)360%60%449911
migrateTabletsForSmoothUpgrade()31513%1150%127901
enqueueWarmupTask(CloudTabletRebalancer.WarmupTabletTask)300%20%226611
revertWarmupState(CloudTabletRebalancer.WarmupTabletTask)290%n/a113311
handleWarmupBatchFailure(List, Exception)260%40%336611
getTabletSizeInBes(long, CloudReplica, ConcurrentHashMap)250%40%335511
dispatchWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)220%40%337711
runAfterCatalogReady()217477%4660%4673201
pickRandomTablet(Set)210%20%224411
flushExpiredWarmupBatches()201441%3125%234701
getCurrentTaskTimeout(String)200%40%337711
checkTableBalanceConflict(long, long, CloudReplica, ConcurrentHashMap)200%20%223311
getTransferPair(List, Map, long, CloudTabletRebalancer.TransferPairInfo)185675%4660%4651301
lambda$completeRouteInfo$5(long, long[], List, Database, Table, Partition, MaterializedIndex, String)1621493%92573%81825101
lambda$checkInflightWarmUpCacheAsync$3(CloudTabletRebalancer.InfightTablet)160%20%225511
updateBalanceStatus(CloudTabletRebalancer.BalanceType)140%40%335511
lambda$batchUpdateCloudReplicaInfoEditlogs$13(UpdateCloudReplicaInfo)130%n/a112211
findSourceBackend(List, Map)125582%8850%7931501
isTransferValid(long, long, long, long)103879%7541%671601
initializeWarmupExecutorsIfNeeded()96888%3562%3532001
getCurrentBalanceType(String)91765%2250%233801
sendPreHeatingRpc(Tablet, long, long)90%n/a112211
findDestinationBackend(List, Map, long)87390%71161%61021801
addTabletMigrationTask(Long, Long)80%n/a112211
completeRouteInfo()74787%2100%0231301
globalBalance()614496%10100%0632701
balanceAllPartitions()614195%10100%0632701
balanceAllTables()614195%10100%0632701
buildClusterToBackendMap()56092%1375%1321301
lambda$initializeWarmupExecutorsIfNeeded$2()5444%n/a012501
lambda$sendWarmupBatch$7(CloudTabletRebalancer.WarmupTabletTask)50%n/a111111
lambda$dispatchWarmupBatch$6(CloudTabletRebalancer.WarmupBatchKey, List)50%n/a111111
lambda$checkInflightWarmUpCacheAsync$4(CloudTabletRebalancer.InfightTask)50%n/a111111
isComputeGroupBalanceChanged(String)42184%3350%341601
processFailedWarmupTasks()4866%1150%121301
lambda$statRouteInfo$10(ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap, Database, Table, Partition, MaterializedIndex, String)15998%21688%21003301
getTabletNumByBackendId(long)4295%3562%350901
lambda$countActiveBackends$12(Long)1794%3350%340201
loopCloudReplica(CloudTabletRebalancer.Operator)97100%14100%0802301
fillBeToTablets(long, long, long, long, Tablet, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)85100%n/a0101301
CloudTabletRebalancer(CloudSystemInfoService)72100%n/a0101701
getSnapshotTabletsInPrimaryByBeId(Long)60100%1787%1501201
statRouteInfo()57100%n/a0101401
balanceInPartition(List, String, List)39100%4100%030701
getSnapshotTabletsInSecondaryByBeId(Long)32100%4100%030701
balanceInTable(List, String, List)23100%2100%020401
performBalancing()22100%6650%670701
getSnapshotTabletsInPrimaryAndSecondaryByBeId(Long)16100%n/a010401
lambda$initializeWarmupExecutorsIfNeeded$1(Runnable)11100%n/a010301
lambda$initializeWarmupExecutorsIfNeeded$0(Runnable)11100%n/a010301
calculateTransferNum(long, long)8100%n/a010101
lambda$calculateTotalTablets$11(Map, Long)8100%n/a010101
calculateTotalTablets(List, Map)7100%n/a010301
countActiveBackends(List)7100%n/a010301
lambda$statRouteInfo$9(Long)4100%n/a010101
lambda$statRouteInfo$8(Long)4100%n/a010101
static {...}4100%n/a010101
isInited()100%n/a010101