RoutineLoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total752 of 2,22866%89 of 20656%781681534911265
getMinTaskBeId(String)1030%120%77222211
getAvailableBeForTask(long, long)7911158%141653%1316124001
checkPrivAndGetAllJobs(String)700%120%77171711
cleanOverLimitRoutineLoadJobs()60811%8220%56202301
getAvailableBackendIds(long)594543%6650%67102301
getTagsFromReplicaAllocation(long, long)510%20%22111111
getJobByName(String)360%40%338811
addRoutineLoadJob(RoutineLoadJob, String, String)315061%2250%2321201
checkPrivAndGetJob(String, String)308072%1787%1551901
isInBlacklist(long)271128%3125%235801
getJob(String, String, boolean, PatternMatcher)2610079%41477%41062801
getSizeOfIdToRoutineLoadTask()220%20%225511
getBeCurrentTasksNumMap()195273%1583%1411101
pauseRoutineLoadJob(PauseRoutineLoadCommand)187380%3350%2452101
resumeRoutineLoadJob(ResumeRoutineLoadCommand)186578%3350%2452301
replayChangeRoutineLoadJob(RoutineLoadOperation)183163%n/a0151301
alterRoutineLoadJob(AlterRoutineLoadCommand)143068%1375%1321001
createRoutineLoadJob(CreateRoutineLoadInfo, ConnectContext)138186%1375%1311901
addToBlacklist(long)90%n/a112211
getTotalMaxConcurrentTaskNum()80%n/a111111
getAllRoutineLoadJobs()70%n/a111111
readFields(DataInput)56692%1787%1511601
lambda$getJob$9(PatternMatcher, RoutineLoadJob)50%n/a111111
getAvailableBackendIdsForUt(long)40%n/a111111
sortRoutineLoadJob(List)35594%31178%3821501
cleanOldRoutineLoadJobs()3770%1150%121401
lambda$cleanOverLimitRoutineLoadJobs$11(RoutineLoadJob)30%n/a111111
lambda$getTotalMaxConcurrentTaskNum$3(Integer)30%n/a111111
getRoutineLoadJobByMultiLoadTaskTxnId(long)21990%1150%121401
checkTaskInJob(RoutineLoadTaskInfo)21588%1150%121401
lambda$isNameUsed$7(RoutineLoadJob)2675%1150%120101
lambda$getActiveRoutineLoadJobs$0(RoutineLoadJob)2675%1150%120101
clearRoutineLoadJobIf(Predicate)66100%4100%0301901
unprotectedRemoveJobFromDb(RoutineLoadJob)55100%4100%030601
getClusterIdleSlotNum()53100%4100%0301001
stopRoutineLoadJob(StopRoutineLoadCommand)52100%n/a0101201
unprotectedAddJob(RoutineLoadJob)34100%n/a010801
isNameUsed(Long, String)34100%4100%030901
RoutineLoadManager()28100%n/a010801
replayRemoveOldRoutineLoad(RoutineLoadOperation)24100%1150%120701
write(DataOutput)22100%2100%020501
updateRoutineLoadJob()20100%4100%030501
getJob(String, String)17100%2100%020401
replayCreateRoutineLoadJob(RoutineLoadJob)17100%n/a010501
processTimeoutTasks()16100%2100%020401
replayAlterRoutineLoadJob(AlterRoutineLoadJobOperationLog)15100%n/a010401
getRoutineLoadJobByState(Set)13100%n/a010301
updateBeIdToMaxConcurrentTasks()12100%n/a010301
getActiveRoutineLoadJobs()10100%n/a010301
addMultiLoadTaskTxnIdToRoutineLoadJobId(long, long)9100%n/a010201
lambda$getJob$8(RoutineLoadJob)8100%2100%020101
removeMultiLoadTaskTxnIdToRoutineLoadJobId(long)7100%n/a010201
getJob(long)7100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
lambda$getRoutineLoadJobByState$10(Set, RoutineLoadJob)5100%n/a010101
lambda$isNameUsed$6(String, RoutineLoadJob)5100%n/a010101
static {...}4100%n/a010101
getBlacklist()3100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$2(Long)3100%n/a010101
lambda$unprotectedAddJob$5(String)2100%n/a010101
lambda$unprotectedAddJob$4(Long)2100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$1(Long)2100%n/a010101