CloudTabletRebalancer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,881 of 5,63048%417 of 66136%2954176581,2602986
checkInflightWarmUpCacheAsync()2907821%28412%1617506601
migrateTablets(Long, Long)2230%260%1414585811
handleWarmupCompletion(CloudTabletRebalancer.InfightTask, String, boolean, long, List)1510%210%1212333311
checkDecommissionState(Map)1485326%14836%812364701
balanceImpl(List, String, Map, CloudTabletRebalancer.BalanceType, List)1357736%26823%1618314801
balanceAllPartitionsByPhase(CloudTabletRebalancer.ActiveSchedulePhase)1354926%12425%79273801
balanceAllTablesByPhase(CloudTabletRebalancer.ActiveSchedulePhase)1354926%12425%79273801
globalBalance()1243923%12425%79243201
updateBeToTablets(long, long, long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)1050%160%99262611
lambda$batchUpdateCloudReplicaInfoEditlogs$17(String, List, CloudTabletRebalancer.LocationKey, List)1030%20%22272711
updateClusterToBeMap(long, long, String, List)960%160%99323211
preheatAndUpdateTablet(long, long, long, String, CloudTabletRebalancer.BalanceType)940%40%33181811
sendPreHeatingRpc(List, long, long)920%40%33232311
sendCheckWarmUpCacheAsyncRpc(List, long)910%40%33222211
sendWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)770%80%55161611
batchUpdateCloudReplicaInfoEditlogs(List, CloudTabletRebalancer.StatType)565549%5550%46122501
performBalancing()517358%321836%2526123401
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)410%n/a116611
reservoirPick(Set, Set, Set, boolean)390%120%77121211
checkGlobalBalanceConflict(long, long, TabletMeta, ConcurrentHashMap, ConcurrentHashMap)380%40%337711
getTabletSizeInParts(long, TabletMeta, ConcurrentHashMap)360%60%449911
isInternalDbId(Long)331835%9325%6781201
enqueueWarmupTask(CloudTabletRebalancer.WarmupTabletTask)300%20%226611
revertWarmupState(CloudTabletRebalancer.WarmupTabletTask)270%n/a113311
shouldForceInactivePhase(boolean)26721%5116%3491201
handleWarmupBatchFailure(List, Exception)260%40%336611
getTabletSizeInBes(long, TabletMeta, ConcurrentHashMap)250%40%335511
runAfterCatalogReady()237777%5758%5783401
dispatchWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)220%40%337711
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
migrateTabletsForSmoothUpgrade()181137%1150%123601
balanceInPartition(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1716890%31583%31054501
balanceInTable(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1714389%31381%3953801
lambda$checkInflightWarmUpCacheAsync$3(CloudTabletRebalancer.InfightTablet)170%20%225511
lambda$completeRouteInfo$5(long, long[], List, Database, Table, Partition, MaterializedIndex, String)1621393%92573%81825101
updateBalanceStatus(CloudTabletRebalancer.BalanceType)140%40%335511
lambda$batchUpdateCloudReplicaInfoEditlogs$16(UpdateCloudReplicaInfo)130%n/a112211
findSourceBackend(List, Map)125582%8850%7931501
findDestinationBackend(List, Map, long)107187%9950%81031801
isTransferValid(long, long, long, long)103879%7541%671601
getActiveTabletIds()103879%3562%2541301
initializeWarmupExecutorsIfNeeded()96888%3562%3532001
getCurrentBalanceType(String)91765%2250%233801
addTabletMigrationTask(Long, Long)80%n/a112211
completeRouteInfo()74787%2100%0231301
lambda$partitionEntryComparator$13(Map.Entry, Map.Entry)69193%3562%2511701
lambda$tableEntryComparator$12(Map.Entry, Map.Entry)69193%3562%2511701
buildClusterToBackendMap()56092%1375%1321301
lambda$initializeWarmupExecutorsIfNeeded$2()5444%n/a012501
lambda$dispatchWarmupBatch$6(CloudTabletRebalancer.WarmupBatchKey, List)50%n/a111111
isComputeGroupBalanceChanged(String)42184%3350%341601
getClusterNameByClusterId(String)41376%2250%231601
processFailedWarmupTasks()4866%1150%121301
lambda$sendWarmupBatch$7(CloudTabletRebalancer.WarmupTabletTask)40%n/a111111
lambda$checkInflightWarmUpCacheAsync$4(CloudTabletRebalancer.InfightTask)40%n/a111111
lambda$statRouteInfo$11(Map, Map, Map, Map, Map, Map, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap, Database, Table, Partition, MaterializedIndex, String)22899%32187%31304101
getTabletNumByBackendId(long)4295%3562%350901
lambda$countActiveBackends$15(Long)1794%3350%340201
statRouteInfo()123100%n/a0102601
CloudTabletRebalancer(CloudSystemInfoService)113100%n/a0102601
loopCloudReplica(CloudTabletRebalancer.Operator)97100%14100%0802301
fillBeToTablets(long, long, long, long, long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)88100%n/a0101301
getSnapshotTabletsInPrimaryByBeId(Long)34100%1375%130801
resetCloudBalanceMetric(CloudTabletRebalancer.StatType)34100%2675%250801
shouldRefreshActiveTabletIds(long)24100%4100%030301
getSnapshotTabletsInSecondaryByBeId(Long)19100%2100%020501
getSnapshotTabletsInPrimaryAndSecondaryByBeId(Long)16100%n/a010401
static {...}16100%n/a010201
refreshActiveTabletIdsIfNeeded()15100%2100%020601
lambda$statRouteInfo$8(Database, Long)14100%1375%130201
lambda$initializeWarmupExecutorsIfNeeded$1(Runnable)11100%n/a010301
lambda$initializeWarmupExecutorsIfNeeded$0(Runnable)11100%n/a010301
calculateTransferNum(long, long)8100%n/a010101
lambda$calculateTotalTablets$14(Map, Long)8100%n/a010101
calculateTotalTablets(List, Map)7100%n/a010301
countActiveBackends(List)7100%n/a010301
lambda$statRouteInfo$10(Long)4100%n/a010101
lambda$statRouteInfo$9(Long)4100%n/a010101
tableEntryComparator()100%n/a010101
partitionEntryComparator()100%n/a010101
isInited()100%n/a010101