CloudTabletRebalancer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,865 of 6,18137%554 of 75726%3674818941,39645102
checkInflightWarmUpCacheAsync()3670%320%1717666611
balanceImpl(List, String, Map, CloudTabletRebalancer.BalanceType, List)2320%400%2121525211
checkDecommissionState(Map)2010%220%1212474711
migrateTablets(Long, Long)1843917%22415%1314505801
balanceAllPartitionsByPhase(CloudTabletRebalancer.ActiveSchedulePhase)1840%160%99383811
balanceAllTablesByPhase(CloudTabletRebalancer.ActiveSchedulePhase)1840%160%99383811
globalBalance()1770%160%99363611
balanceInPartition(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1650%220%1212363611
handleWarmupCompletion(CloudTabletRebalancer.InfightTask, String, boolean, long, List)1490%210%1212333311
lambda$completeRouteInfo$6(String, long[], long, long[], List, Database, Table, Partition, MaterializedIndex, String)14811243%271332%1621315701
balanceInTable(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1400%160%99323211
performBalancing()1240%500%2626343411
batchUpdateCloudReplicaInfoEditlogs(List, CloudTabletRebalancer.StatType)1110%100%66252511
sendPreHeatingRpc(List, long, long)1040%80%55262611
updateClusterToBeMap(long, long, String, List)941513%16211%910313601
lambda$batchUpdateCloudReplicaInfoEditlogs$21(String, List, CloudTabletRebalancer.LocationKey, List)940%20%22272711
sendCheckWarmUpCacheAsyncRpc(List, long)910%40%33222211
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$13(Map, Map, Map, Map, Map, Map, Map, ConcurrentHashMap, ConcurrentHashMap, Function, ConcurrentHashMap, Function, ConcurrentHashMap, Database, Table, Partition, MaterializedIndex, String)7216269%131959%1117175001
findSourceBackend(List, Map)670%160%99151511
initializeWarmupExecutorsIfNeeded()532431%4450%45132001
isInternalDbId(Long)510%120%77121211
isTransferValid(long, long, long, long)480%120%776611
getTabletNumByBackendId(long)440%80%559911
getActiveTabletIds()371122%6225%4591301
flushExpiredWarmupBatches()340%40%337711
getCurrentBalanceType(String)260%40%338811
isComputeGroupBalanceChanged(String)250%60%446611
dispatchWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)220%40%337711
isConflict(long, long, long, CloudTabletRebalancer.BalanceType, String, CloudTabletRebalancer.RouteVariant)2119090%122264%121884401
getCurrentTaskTimeout(String)200%40%337711
lambda$countActiveBackends$19(Long)180%60%442211
lambda$checkInflightWarmUpCacheAsync$4(CloudTabletRebalancer.InfightTablet)170%20%225511
moveInView(Map, Long, Long, Long)160%n/a113311
completeRouteInfo()157282%2250%2361701
updateBeToTablets(Long, Long, Long, String, CloudTabletRebalancer.RouteVariant, ConcurrentHashMap)146081%5758%5741701
updateBalanceStatus(CloudTabletRebalancer.BalanceType)140%40%335511
buildPartitionViews(Long, String)129889%4866%4742601
lambda$batchUpdateCloudReplicaInfoEditlogs$20(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)98290%2250%2321701
lambda$initializeWarmupExecutorsIfNeeded$3()90%n/a115511
buildTableView(Long, String)88391%3975%3732101
calculateTransferNum(long, long)80%n/a111111
lambda$calculateTotalTablets$18(Map, Long)80%n/a111111
handleWarmupBatchFailure(List, Exception)71973%1375%131601
calculateTotalTablets(List, Map)70%n/a113311
countActiveBackends(List)70%n/a113311
lambda$partitionEntryComparator$16(Long, Long)68793%3562%3521701
lambda$statRouteInfo$10(Database, Long)6857%3125%230201
buildClusterToBackendMap()56092%1375%1321301
shouldForceInactivePhase(boolean)52884%1583%1421201
lambda$dispatchWarmupBatch$8(CloudTabletRebalancer.WarmupBatchKey, List)50%n/a111111
lambda$tableEntryComparator$15(Long, Long)48995%2675%2511701
enqueueWarmupTask(CloudTabletRebalancer.WarmupTabletTask)42686%1150%121601
getClusterNameByClusterId(String)41376%2250%231601
lambda$moveInView$17(Long)40%n/a111111
lambda$statRouteInfo$12(Long)40%n/a111111
lambda$statRouteInfo$11(Long)40%n/a111111
isInited()0%n/a111111
lambda$sendWarmupBatch$9(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
futureRouteBe(long, CloudReplica, String)3093%2466%240501
currentRouteBe(CloudReplica, String)1890%3350%341501
reservoirPick(Set, Set, Set, boolean)3897%3975%3711201
resetCloudBalanceMetric(CloudTabletRebalancer.StatType)3397%3562%351801
refreshActiveTabletIdsIfNeeded()1493%1150%121601
CloudTabletRebalancer(CloudSystemInfoService, CloudTabletRebalancerMetrics)137100%n/a0103201
statRouteInfo()123100%n/a0102801
countRoutes(Map, MaterializedIndex, String, CloudTabletRebalancer.RouteVariant)54100%1787%1501001
getSnapshotTabletsInPrimaryAndSecondaryByBeId(Long)42100%n/a0101001
addFutureTablet(Map, Tablet, String)38100%1375%130701
staleRouteSweepNeeded(Set)37100%8100%0501101
transferTablet(Long, Long, Long, String, CloudTabletRebalancer.BalanceType, List)36100%n/a010501
getSnapshotTabletsInPrimaryByBeId(Long)28100%n/a010601
revertWarmupState(CloudTabletRebalancer.WarmupTabletTask)28100%n/a010301
shouldRefreshActiveTabletIds(long)24100%4100%030301
lambda$newGlobalTabletSetFactory$7(Map, Long)18100%2100%020401
static {...}18100%n/a010301
processFailedWarmupTasks()17100%2100%020501
getSnapshotTabletsInSecondaryByBeId(Long)16100%n/a010401
releaseSchedulingIndexes()15100%n/a010501
newGlobalTabletSetFactory(Map)10100%2100%020301
fillGlobalBeToTablets(Long, Long, Function, ConcurrentHashMap)9100%n/a010201
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$addFutureTablet$14(Long)4100%n/a010101
newSnapshotTabletSet(int)100%n/a010101
tableEntryComparator()100%n/a010101
partitionEntryComparator()100%n/a010101
lambda$static$0(Long)100%n/a010101