CloudTabletRebalancer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total5,048 of 5,4968%572 of 6116%3693901,1121,2047384
checkInflightWarmUpCacheAsync()3690%320%1717666611
lambda$completeRouteInfo$5(long, long[], List, Database, Table, Partition, MaterializedIndex, String)2290%340%1818515111
lambda$statRouteInfo$11(Map, Map, Map, Map, Map, Map, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap, Database, Table, Partition, MaterializedIndex, String)2270%240%1313404011
balanceImpl(List, String, Map, CloudTabletRebalancer.BalanceType, List)2200%340%1818494911
migrateTablets(Long, Long)2080%180%1010555511
checkDecommissionState(Map)2010%220%1212474711
balanceInPartition(List, String, List, CloudTabletRebalancer.ActiveSchedulePhase)1850%180%1010454511
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)1520%210%1212333311
statRouteInfo()1230%n/a11262611
batchUpdateCloudReplicaInfoEditlogs(List, CloudTabletRebalancer.StatType)1110%100%66252511
performBalancing()1060%440%2323292911
lambda$batchUpdateCloudReplicaInfoEditlogs$17(String, List, CloudTabletRebalancer.LocationKey, List)1030%20%22272711
runAfterCatalogReady()990%100%66333311
loopCloudReplica(CloudTabletRebalancer.Operator)970%140%88232311
preheatAndUpdateTablet(Tablet, long, long, String, CloudTabletRebalancer.BalanceType, Map)970%40%33181811
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
getSnapshotTabletsInPrimaryByBeId(Long)600%80%55121211
updateBeToTablets(Tablet, long, long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)600%n/a119911
updateClusterToBeMap(Tablet, long, String, List)580%60%44171711
completeRouteInfo()540%20%22131311
isInternalDbId(Long)510%120%77121211
isTransferValid(long, long, long, long)480%120%776611
getActiveTabletIds()480%80%55131311
getTabletNumByBackendId(long)440%80%559911
transferTablet(Tablet, long, long, String, CloudTabletRebalancer.BalanceType, List)420%n/a116611
checkGlobalBalanceConflict(long, long, CloudReplica, ConcurrentHashMap, ConcurrentHashMap)380%40%337711
isConflict(long, long, CloudReplica, CloudTabletRebalancer.BalanceType, ConcurrentHashMap, ConcurrentHashMap)370%80%558811
getTabletSizeInParts(long, CloudReplica, ConcurrentHashMap)360%60%449911
flushExpiredWarmupBatches()340%40%337711
getSnapshotTabletsInSecondaryByBeId(Long)320%40%337711
migrateTabletsForSmoothUpgrade()31513%1150%127901
enqueueWarmupTask(CloudTabletRebalancer.WarmupTabletTask)300%20%226611
revertWarmupState(CloudTabletRebalancer.WarmupTabletTask)280%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
dispatchWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)220%40%337711
getCurrentTaskTimeout(String)200%40%337711
checkTableBalanceConflict(long, long, CloudReplica, ConcurrentHashMap)200%20%223311
lambda$countActiveBackends$15(Long)180%60%442211
lambda$checkInflightWarmUpCacheAsync$3(CloudTabletRebalancer.InfightTablet)170%20%225511
getSnapshotTabletsInPrimaryAndSecondaryByBeId(Long)160%n/a114411
updateBalanceStatus(CloudTabletRebalancer.BalanceType)140%40%335511
lambda$statRouteInfo$8(Database, Long)140%40%332211
lambda$batchUpdateCloudReplicaInfoEditlogs$16(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$14(Map, Long)80%n/a111111
calculateTotalTablets(List, Map)70%n/a113311
countActiveBackends(List)70%n/a113311
lambda$partitionEntryComparator$13(Map.Entry, Map.Entry)69193%3562%3521701
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$tableEntryComparator$12(Map.Entry, Map.Entry)49395%2675%2511701
getClusterNameByClusterId(String)41376%2250%231601
lambda$statRouteInfo$10(Long)40%n/a111111
lambda$statRouteInfo$9(Long)40%n/a111111
isInited()0%n/a111111
pickTabletPreferCold(long, Set, Set, Set)4295%51168%591901
reservoirPick(Set, Set, Set, boolean)4297%3975%3711201
resetCloudBalanceMetric(CloudTabletRebalancer.StatType)3397%3562%351801
CloudTabletRebalancer(CloudSystemInfoService)107100%n/a0102401
static {...}16100%n/a010201
tableEntryComparator()100%n/a010101
partitionEntryComparator()100%n/a010101