CloudTabletRebalancer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,505 of 5,80839%465 of 67330%3244327891,3044095
checkInflightWarmUpCacheAsync()2897821%28412%1617506601
migrateTablets(Long, Long)2230%260%1414585811
handleWarmupCompletion(CloudTabletRebalancer.InfightTask, String, boolean, long, List)1490%210%1212333311
checkDecommissionState(Map)1485326%14836%812364701
balanceImpl(List, String, Map, CloudTabletRebalancer.BalanceType, List)1397735%26823%1618304701
balanceAllPartitionsByPhase(CloudTabletRebalancer.ActiveSchedulePhase)1354926%12425%79273801
balanceAllTablesByPhase(CloudTabletRebalancer.ActiveSchedulePhase)1354926%12425%79273801
balanceInPartition(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1246132%12633%710324501
globalBalance()1243923%12425%79243201
balanceInTable(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1243622%12425%79313801
updateClusterToBeMap(long, long, String, List)1090%180%1010363611
sendPreHeatingRpc(List, long, long)1040%80%55262611
lambda$batchUpdateCloudReplicaInfoEditlogs$19(String, List, CloudTabletRebalancer.LocationKey, List)1030%20%22272711
updateBeToTablets(Long, Long, Long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)970%160%99262611
lambda$partitionEntryComparator$15(Map.Entry, Map.Entry)970%80%55171711
lambda$tableEntryComparator$14(Map.Entry, Map.Entry)970%80%55171711
preheatAndUpdateTablet(Long, Long, Long, String, CloudTabletRebalancer.BalanceType, Map)940%40%33171711
sendCheckWarmUpCacheAsyncRpc(List, long)910%40%33222211
performBalancing()772927%37715%2223212901
sendWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)770%80%55161611
lambda$statRouteInfo$13(Map, Map, Map, Map, Map, Map, ConcurrentHashMap, ConcurrentHashMap, Function, ConcurrentHashMap, Function, ConcurrentHashMap, Database, Table, Partition, MaterializedIndex, String)5618977%102066%91684901
batchUpdateCloudReplicaInfoEditlogs(List, CloudTabletRebalancer.StatType)565549%5550%46122501
isInternalDbId(Long)510%120%77121211
isConflict(long, long, long, CloudTabletRebalancer.BalanceType, ConcurrentHashMap, ConcurrentHashMap)460%100%66111111
pickTabletPreferCold(long, Set, Set, Set)440%160%999911
transferTablet(Long, Long, Long, String, CloudTabletRebalancer.BalanceType, List)400%n/a115511
reservoirPick(Set, Set, Set, boolean)390%120%77121211
checkGlobalBalanceConflict(long, long, TabletMeta, ConcurrentHashMap, ConcurrentHashMap)380%40%337711
getActiveTabletIds()371122%6225%4591301
getTabletSizeInParts(long, TabletMeta, ConcurrentHashMap)360%60%449911
migrateTabletsForSmoothUpgrade()31513%1150%127901
enqueueWarmupTask(CloudTabletRebalancer.WarmupTabletTask)300%20%226611
revertWarmupState(CloudTabletRebalancer.WarmupTabletTask)290%n/a113311
getSnapshotTabletsInPrimaryByBeId(Long)280%n/a116611
handleWarmupBatchFailure(List, Exception)260%40%336611
lambda$completeRouteInfo$6(String, long[], long, long[], List, Database, Table, Partition, MaterializedIndex, String)2523590%103075%92135701
getTabletSizeInBes(long, TabletMeta, ConcurrentHashMap)250%40%335511
dispatchWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)220%40%337711
runAfterCatalogReady()219181%4660%4673601
getTransferPair(List, Map, long, CloudTabletRebalancer.TransferPairInfo)205472%5550%5661301
flushExpiredWarmupBatches()201441%3125%234701
getCurrentTaskTimeout(String)200%40%337711
checkTableBalanceConflict(long, long, TabletMeta, ConcurrentHashMap)200%20%223311
lambda$checkInflightWarmUpCacheAsync$4(CloudTabletRebalancer.InfightTablet)170%20%225511
getSnapshotTabletsInSecondaryByBeId(Long)160%n/a114411
fillBeToTablets(long, long, long, long, long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)160%n/a113311
updateBalanceStatus(CloudTabletRebalancer.BalanceType)140%40%335511
lambda$batchUpdateCloudReplicaInfoEditlogs$18(UpdateCloudReplicaInfo)130%n/a112211
findSourceBackend(List, Map)125582%8850%7931501
fillBeToTablets(Long, Long, Long, Long, Long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)120%n/a112211
findDestinationBackend(List, Map, long)107187%9950%81031801
isTransferValid(long, long, long, long)103879%7541%671601
initializeWarmupExecutorsIfNeeded()96888%3562%3532001
getCurrentBalanceType(String)91765%2250%233801
staleRouteSweepNeeded(Set)82978%2675%2531101
addTabletMigrationTask(Long, Long)80%n/a112211
completeRouteInfo()78091%4100%0331701
buildClusterToBackendMap()56092%1375%1321301
lambda$initializeWarmupExecutorsIfNeeded$3()5444%n/a012501
lambda$dispatchWarmupBatch$8(CloudTabletRebalancer.WarmupBatchKey, List)50%n/a111111
isComputeGroupBalanceChanged(String)42184%3350%341601
getClusterNameByClusterId(String)41376%2250%231601
processFailedWarmupTasks()4866%1150%121301
lambda$statRouteInfo$12(Long)40%n/a111111
tableEntryComparator()0%n/a111111
partitionEntryComparator()0%n/a111111
lambda$sendWarmupBatch$9(CloudTabletRebalancer.WarmupTabletTask)0%n/a111111
lambda$checkInflightWarmUpCacheAsync$5(CloudTabletRebalancer.InfightTask)0%n/a111111
getTabletNumByBackendId(long)4295%3562%350901
lambda$static$0(Long)0%n/a111111
lambda$countActiveBackends$17(Long)1794%3350%340201
statRouteInfo()135100%n/a0103001
CloudTabletRebalancer(CloudSystemInfoService, CloudTabletRebalancerMetrics)116100%n/a0102701
loopCloudReplica(CloudTabletRebalancer.Operator)106100%14100%0802401
fillBeToTablets(Long, Long, Long, Long, Long, Function, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)69100%n/a0101201
getSnapshotTabletsInPrimaryAndSecondaryByBeId(Long)42100%n/a0101001
resetCloudBalanceMetric(CloudTabletRebalancer.StatType)34100%2675%250801
lambda$newGlobalTabletSetFactory$7(Map, Long)18100%2100%020401
static {...}18100%n/a010301
lambda$statRouteInfo$10(Database, Long)14100%1375%130201
lambda$initializeWarmupExecutorsIfNeeded$2(Runnable)11100%n/a010301
lambda$initializeWarmupExecutorsIfNeeded$1(Runnable)11100%n/a010301
newGlobalTabletSetFactory(Map)10100%2100%020301
calculateTransferNum(long, long)8100%n/a010101
lambda$calculateTotalTablets$16(Map, Long)8100%n/a010101
tabletSetSize(Set)7100%2100%020101
addSnapshotTablets(Set, Set)7100%2100%020301
newGlobalTabletSet(int)7100%2100%020201
calculateTotalTablets(List, Map)7100%n/a010301
countActiveBackends(List)7100%n/a010301
CloudTabletRebalancer(CloudSystemInfoService)5100%n/a010201
newRouteInfoList(int)5100%n/a010101
lambda$statRouteInfo$11(Long)4100%n/a010101
newSnapshotTabletSet(int)100%n/a010101
isInited()100%n/a010101