CloudTabletRebalancer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total4,376 of 4,4521%447 of 4470%2962989439617274
checkInflightWarmUpCacheAsync()3680%320%1717666611
lambda$completeRouteInfo$5(long, long[], List, Database, Table, Partition, MaterializedIndex, String)2300%340%1818515111
migrateTablets(Long, Long)2050%180%1010545411
checkDecommissionState(Map)1990%220%1212464611
balanceImpl(List, String, Map, CloudTabletRebalancer.BalanceType, List)1960%300%1616434311
lambda$statRouteInfo$10(ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap, Database, Table, Partition, MaterializedIndex, String)1610%180%1010333311
handleWarmupCompletion(CloudTabletRebalancer.InfightTask, String, boolean, long, List)1530%210%1212333311
globalBalance()1500%100%66272711
balanceAllPartitions()1470%100%66272711
balanceAllTables()1470%100%66272711
lambda$batchUpdateCloudReplicaInfoEditlogs$14(String, List, Long, List)1470%40%33323211
batchUpdateCloudReplicaInfoEditlogs(List, CloudTabletRebalancer.StatType)1130%100%66272711
preheatAndUpdateTablet(Tablet, long, long, String, CloudTabletRebalancer.BalanceType, Map)990%40%33191911
loopCloudReplica(CloudTabletRebalancer.Operator)970%140%88232311
runAfterCatalogReady()950%100%66323211
sendPreHeatingRpc(List, long, long)920%40%33232311
sendCheckWarmUpCacheAsyncRpc(List, long)910%40%33222211
fillBeToTablets(long, long, long, long, Tablet, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)850%n/a11131311
findDestinationBackend(List, Map, long)810%180%1010181811
initializeWarmupExecutorsIfNeeded()770%80%55202011
sendWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)770%80%55161611
getTransferPair(List, Map, long, CloudTabletRebalancer.TransferPairInfo)740%100%66131311
findSourceBackend(List, Map)670%160%99151511
buildClusterToBackendMap()650%40%33131311
updateBeToTablets(Tablet, long, long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)620%n/a119911
getSnapshotTabletsInPrimaryByBeId(Long)600%80%55121211
updateClusterToBeMap(Tablet, long, String, List)600%60%44171711
statRouteInfo()570%n/a11141411
completeRouteInfo()540%20%22131311
isTransferValid(long, long, long, long)480%120%776611
getTabletNumByBackendId(long)440%80%559911
transferTablet(Tablet, long, long, String, CloudTabletRebalancer.BalanceType, List)410%n/a116611
balanceInPartition(List, String, List)390%40%337711
checkGlobalBalanceConflict(long, long, CloudReplica, ConcurrentHashMap, ConcurrentHashMap)380%40%337711
isConflict(long, long, CloudReplica, CloudTabletRebalancer.BalanceType, ConcurrentHashMap, ConcurrentHashMap)370%80%558811
migrateTabletsForSmoothUpgrade()360%20%229911
getTabletSizeInParts(long, CloudReplica, ConcurrentHashMap)360%60%449911
flushExpiredWarmupBatches()340%40%337711
getSnapshotTabletsInSecondaryByBeId(Long)320%40%337711
enqueueWarmupTask(CloudTabletRebalancer.WarmupTabletTask)300%20%226611
revertWarmupState(CloudTabletRebalancer.WarmupTabletTask)290%n/a113311
getCurrentBalanceType(String)260%40%338811
handleWarmupBatchFailure(List, Exception)260%40%336611
isComputeGroupBalanceChanged(String)250%60%446611
getTabletSizeInBes(long, CloudReplica, ConcurrentHashMap)250%40%335511
balanceInTable(List, String, List)230%20%224411
performBalancing()220%120%777711
dispatchWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)220%40%337711
pickRandomTablet(Set)210%20%224411
getCurrentTaskTimeout(String)200%40%337711
checkTableBalanceConflict(long, long, CloudReplica, ConcurrentHashMap)200%20%223311
lambda$countActiveBackends$12(Long)180%60%442211
getSnapshotTabletsInPrimaryAndSecondaryByBeId(Long)160%n/a114411
lambda$checkInflightWarmUpCacheAsync$3(CloudTabletRebalancer.InfightTablet)160%20%225511
updateBalanceStatus(CloudTabletRebalancer.BalanceType)140%40%335511
lambda$batchUpdateCloudReplicaInfoEditlogs$13(UpdateCloudReplicaInfo)130%n/a112211
processFailedWarmupTasks()120%20%223311
lambda$initializeWarmupExecutorsIfNeeded$1(Runnable)110%n/a113311
lambda$initializeWarmupExecutorsIfNeeded$0(Runnable)110%n/a113311
sendPreHeatingRpc(Tablet, long, long)90%n/a112211
lambda$initializeWarmupExecutorsIfNeeded$2()90%n/a115511
calculateTransferNum(long, long)80%n/a111111
addTabletMigrationTask(Long, Long)80%n/a112211
lambda$calculateTotalTablets$11(Map, Long)80%n/a111111
calculateTotalTablets(List, Map)70%n/a113311
countActiveBackends(List)70%n/a113311
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
lambda$statRouteInfo$9(Long)40%n/a111111
lambda$statRouteInfo$8(Long)40%n/a111111
isInited()0%n/a111111
CloudTabletRebalancer(CloudSystemInfoService)72100%n/a0101701
static {...}4100%n/a010101