CloudTabletRebalancer

A different version of class was executed at runtime.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total5,797 of 5,7970%679 of 6790%4434431,3111,311103103
checkInflightWarmUpCacheAsync()3670%320%1717666611
lambda$completeRouteInfo$6(long, long[], List, Database, Table, Partition, MaterializedIndex, String)2470%380%2020555511
lambda$statRouteInfo$18(Map, Map, Map, Map, Map, Map, ConcurrentHashMap, ConcurrentHashMap, Function, ConcurrentHashMap, Function, ConcurrentHashMap, Database, Table, Partition, MaterializedIndex, String)2450%300%1616494911
migrateTablets(Long, Long)2230%260%1414585811
balanceImpl(List, String, Map, CloudTabletRebalancer.BalanceType, List)2140%340%1818474711
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)1490%210%1212333311
statRouteInfo()1350%n/a11303011
performBalancing()1240%500%2626343411
CloudTabletRebalancer(CloudSystemInfoService, CloudTabletRebalancerMetrics)1160%n/a11272711
runAfterCatalogReady()1150%120%77383811
batchUpdateCloudReplicaInfoEditlogs(List, CloudTabletRebalancer.StatType)1110%100%66252511
loopCloudReplica(CloudTabletRebalancer.Operator)1070%140%88242411
sendPreHeatingRpc(List, long, long)1040%80%55262611
updateBeToTablets(Long, Long, Long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)970%160%99262611
lambda$partitionEntryComparator$20(Map.Entry, Map.Entry)970%80%55171711
lambda$tableEntryComparator$19(Map.Entry, Map.Entry)970%80%55171711
updateClusterToBeMap(long, long, String, List)960%160%99323211
lambda$batchUpdateCloudReplicaInfoEditlogs$24(String, List, CloudTabletRebalancer.LocationKey, List)940%20%22272711
preheatAndUpdateTablet(Long, Long, Long, String, CloudTabletRebalancer.BalanceType)930%40%33171711
sendCheckWarmUpCacheAsyncRpc(List, long)910%40%33222211
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
completeRouteInfo()540%20%22131311
isInternalDbId(Long)510%120%77121211
isTransferValid(long, long, long, long)480%120%776611
getActiveTabletIds()480%80%55131311
isConflict(long, long, long, CloudTabletRebalancer.BalanceType, ConcurrentHashMap, ConcurrentHashMap)460%100%66111111
getTabletNumByBackendId(long)440%80%559911
pickTabletPreferCold(long, Set, Set, Set)440%160%999911
fillBeToTablets(Long, Long, Long, Long, Long, Function, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)430%n/a11101011
getSnapshotTabletsInPrimaryAndSecondaryByBeId(Long)420%n/a11101011
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
getTabletSizeInParts(long, TabletMeta, ConcurrentHashMap)360%60%449911
flushExpiredWarmupBatches()340%40%337711
resetCloudBalanceMetric(CloudTabletRebalancer.StatType)340%80%558811
shouldForceInactivePhase(boolean)330%60%44121211
enqueueWarmupTask(CloudTabletRebalancer.WarmupTabletTask)300%20%226611
migrateTabletsForSmoothUpgrade()290%20%226611
revertWarmupState(CloudTabletRebalancer.WarmupTabletTask)290%n/a113311
getSnapshotTabletsInPrimaryByBeId(Long)280%n/a116611
getCurrentBalanceType(String)260%40%338811
handleWarmupBatchFailure(List, Exception)260%40%336611
isComputeGroupBalanceChanged(String)250%60%446611
getTabletSizeInBes(long, TabletMeta, ConcurrentHashMap)250%40%335511
shouldRefreshActiveTabletIds(long)240%40%333311
dispatchWarmupBatch(CloudTabletRebalancer.WarmupBatchKey, List)220%40%337711
releaseSchedulingIndexes()210%n/a115511
getCurrentTaskTimeout(String)200%40%337711
checkTableBalanceConflict(long, long, TabletMeta, ConcurrentHashMap)200%20%223311
lambda$countActiveBackends$22(Long)180%60%442211
lambda$newGlobalTabletSetFactory$12(Map, Long)180%20%224411
static {...}180%n/a113311
getClusterNameByClusterId(String)170%40%336611
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
refreshActiveTabletIdsIfNeeded()150%20%226611
updateBalanceStatus(CloudTabletRebalancer.BalanceType)140%40%335511
lambda$statRouteInfo$15(Database, Long)140%40%332211
fillBeToTablets(Long, Long, Long, Long, Long, ConcurrentHashMap, ConcurrentHashMap, ConcurrentHashMap)120%n/a112211
processFailedWarmupTasks()120%20%223311
lambda$batchUpdateCloudReplicaInfoEditlogs$23(UpdateCloudReplicaInfo)120%n/a112211
lambda$initializeWarmupExecutorsIfNeeded$2(Runnable)110%n/a113311
lambda$initializeWarmupExecutorsIfNeeded$1(Runnable)110%n/a113311
newGlobalTabletSetFactory(Map)100%20%223311
lambda$initializeWarmupExecutorsIfNeeded$3()90%n/a115511
calculateTransferNum(long, long)80%n/a111111
addTabletMigrationTask(Long, Long)80%n/a112211
lambda$calculateTotalTablets$21(Map, Long)80%n/a111111
tabletSetSize(Set)70%20%221111
addSnapshotTablets(Set, Set)70%20%223311
newGlobalTabletSet(int)70%20%222211
calculateTotalTablets(List, Map)70%n/a113311
countActiveBackends(List)70%n/a113311
CloudTabletRebalancer(CloudSystemInfoService)50%n/a112211
newRouteInfoList(int)50%n/a111111
lambda$dispatchWarmupBatch$13(CloudTabletRebalancer.WarmupBatchKey, List)50%n/a111111
lambda$statRouteInfo$17(Long)40%n/a111111
lambda$statRouteInfo$16(Long)40%n/a111111
lambda$fillBeToTablets$10(Long)40%n/a111111
lambda$fillBeToTablets$9(Long)40%n/a111111
lambda$fillBeToTablets$7(Long)40%n/a111111
newSnapshotTabletSet(int)0%n/a111111
tableEntryComparator()0%n/a111111
partitionEntryComparator()0%n/a111111
isInited()0%n/a111111
lambda$sendWarmupBatch$14(CloudTabletRebalancer.WarmupTabletTask)0%n/a111111
lambda$checkInflightWarmUpCacheAsync$5(CloudTabletRebalancer.InfightTask)0%n/a111111
lambda$fillBeToTablets$11(Long)0%n/a111111
lambda$fillBeToTablets$8(Long)0%n/a111111
lambda$static$0(Long)0%n/a111111