CloudTabletRebalancer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,957 of 5,79731%542 of 67920%3514439131,31148103
checkInflightWarmUpCacheAsync()3670%320%1717666611
balanceImpl(List, String, Map, CloudTabletRebalancer.BalanceType, List)2140%340%1818474711
checkDecommissionState(Map)2010%220%1212474711
balanceInPartition(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1850%180%1010454511
migrateTablets(Long, Long)1843917%22415%1314505801
balanceAllPartitionsByPhase(CloudTabletRebalancer.ActiveSchedulePhase)1840%160%99383811
balanceAllTablesByPhase(CloudTabletRebalancer.ActiveSchedulePhase)1840%160%99383811
globalBalance()1630%160%99323211
balanceInTable(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1600%160%99383811
handleWarmupCompletion(CloudTabletRebalancer.InfightTask, String, boolean, long, List)1490%210%1212333311
lambda$completeRouteInfo$6(long, long[], List, Database, Table, Partition, MaterializedIndex, String)1489940%261231%1520315501
performBalancing()1240%500%2626343411
batchUpdateCloudReplicaInfoEditlogs(List, CloudTabletRebalancer.StatType)1110%100%66252511
sendPreHeatingRpc(List, long, long)1040%80%55262611
lambda$batchUpdateCloudReplicaInfoEditlogs$24(String, List, CloudTabletRebalancer.LocationKey, List)940%20%22272711
sendCheckWarmUpCacheAsyncRpc(List, long)910%40%33222211
updateClusterToBeMap(long, long, String, List)811515%14212%89273201
findDestinationBackend(List, Map, long)810%180%1010181811
runAfterCatalogReady()793631%10216%67253801
sendWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)770%80%55161611
getTransferPair(List, Map, long, CloudTabletRebalancer.TransferPairInfo)740%100%66131311
lambda$statRouteInfo$18(Map, Map, Map, Map, Map, Map, ConcurrentHashMap, ConcurrentHashMap, Function, ConcurrentHashMap, Function, ConcurrentHashMap, Database, Table, Partition, MaterializedIndex, String)7217370%121860%1016174901
findSourceBackend(List, Map)670%160%99151511
initializeWarmupExecutorsIfNeeded()532431%4450%45132001
isInternalDbId(Long)510%120%77121211
isTransferValid(long, long, long, long)480%120%776611
isConflict(long, long, long, CloudTabletRebalancer.BalanceType, ConcurrentHashMap, ConcurrentHashMap)460%100%66111111
getTabletNumByBackendId(long)440%80%559911
checkGlobalBalanceConflict(long, long, TabletMeta, ConcurrentHashMap, ConcurrentHashMap)380%40%337711
getActiveTabletIds()371122%6225%4591301
getTabletSizeInParts(long, TabletMeta, ConcurrentHashMap)360%60%449911
flushExpiredWarmupBatches()340%40%337711
getCurrentBalanceType(String)260%40%338811
isComputeGroupBalanceChanged(String)250%60%446611
getTabletSizeInBes(long, TabletMeta, ConcurrentHashMap)250%40%335511
dispatchWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)220%40%337711
getCurrentTaskTimeout(String)200%40%337711
checkTableBalanceConflict(long, long, TabletMeta, ConcurrentHashMap)200%20%223311
lambda$countActiveBackends$22(Long)180%60%442211
lambda$checkInflightWarmUpCacheAsync$4(CloudTabletRebalancer.InfightTablet)170%20%225511
completeRouteInfo()144074%1150%1261301
updateBalanceStatus(CloudTabletRebalancer.BalanceType)140%40%335511
updateBeToTablets(Long, Long, Long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)128587%8850%8952601
lambda$batchUpdateCloudReplicaInfoEditlogs$23(UpdateCloudReplicaInfo)120%n/a112211
migrateTabletsForSmoothUpgrade()111862%2100%022601
lambda$initializeWarmupExecutorsIfNeeded$2(Runnable)110%n/a113311
lambda$initializeWarmupExecutorsIfNeeded$1(Runnable)110%n/a113311
preheatAndUpdateTablet(Long, Long, Long, String, CloudTabletRebalancer.BalanceType)98490%2250%2321701
lambda$initializeWarmupExecutorsIfNeeded$3()90%n/a115511
calculateTransferNum(long, long)80%n/a111111
lambda$calculateTotalTablets$21(Map, Long)80%n/a111111
handleWarmupBatchFailure(List, Exception)71973%1375%131601
calculateTotalTablets(List, Map)70%n/a113311
countActiveBackends(List)70%n/a113311
lambda$partitionEntryComparator$20(Map.Entry, Map.Entry)69193%3562%3521701
lambda$statRouteInfo$15(Database, Long)6857%3125%230201
buildClusterToBackendMap()56092%1375%1321301
shouldForceInactivePhase(boolean)52884%1583%1421201
lambda$dispatchWarmupBatch$13(CloudTabletRebalancer.WarmupBatchKey, List)50%n/a111111
lambda$tableEntryComparator$19(Map.Entry, Map.Entry)49395%2675%2511701
enqueueWarmupTask(CloudTabletRebalancer.WarmupTabletTask)42686%1150%121601
getClusterNameByClusterId(String)41376%2250%231601
lambda$statRouteInfo$17(Long)40%n/a111111
lambda$statRouteInfo$16(Long)40%n/a111111
isInited()0%n/a111111
lambda$sendWarmupBatch$14(CloudTabletRebalancer.WarmupTabletTask)0%n/a111111
lambda$checkInflightWarmUpCacheAsync$5(CloudTabletRebalancer.InfightTask)0%n/a111111
loopCloudReplica(CloudTabletRebalancer.Operator)10598%21285%2822401
pickTabletPreferCold(long, Set, Set, Set)4295%51168%591901
reservoirPick(Set, Set, Set, boolean)3897%3975%3711201
resetCloudBalanceMetric(CloudTabletRebalancer.StatType)3397%3562%351801
refreshActiveTabletIdsIfNeeded()1493%1150%121601
statRouteInfo()135100%n/a0103001
CloudTabletRebalancer(CloudSystemInfoService, CloudTabletRebalancerMetrics)116100%n/a0102701
fillBeToTablets(Long, Long, Long, Long, Long, Function, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)43100%n/a0101001
getSnapshotTabletsInPrimaryAndSecondaryByBeId(Long)42100%n/a0101001
transferTablet(Long, Long, Long, String, CloudTabletRebalancer.BalanceType, List)40100%n/a010501
revertWarmupState(CloudTabletRebalancer.WarmupTabletTask)29100%n/a010301
getSnapshotTabletsInPrimaryByBeId(Long)28100%n/a010601
shouldRefreshActiveTabletIds(long)24100%4100%030301
releaseSchedulingIndexes()21100%n/a010501
lambda$newGlobalTabletSetFactory$12(Map, Long)18100%2100%020401
static {...}18100%n/a010301
getSnapshotTabletsInSecondaryByBeId(Long)16100%n/a010401
fillBeToTablets(long, long, long, long, long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)16100%n/a010301
fillBeToTablets(Long, Long, Long, Long, Long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)12100%n/a010201
processFailedWarmupTasks()12100%2100%020301
newGlobalTabletSetFactory(Map)10100%2100%020301
addTabletMigrationTask(Long, Long)8100%n/a010201
tabletSetSize(Set)7100%2100%020101
addSnapshotTablets(Set, Set)7100%2100%020301
newGlobalTabletSet(int)7100%2100%020201
CloudTabletRebalancer(CloudSystemInfoService)5100%n/a010201
newRouteInfoList(int)5100%n/a010101
lambda$fillBeToTablets$10(Long)4100%n/a010101
lambda$fillBeToTablets$9(Long)4100%n/a010101
lambda$fillBeToTablets$7(Long)4100%n/a010101
newSnapshotTabletSet(int)100%n/a010101
tableEntryComparator()100%n/a010101
partitionEntryComparator()100%n/a010101
lambda$fillBeToTablets$11(Long)100%n/a010101
lambda$fillBeToTablets$8(Long)100%n/a010101
lambda$static$0(Long)100%n/a010101