RoutineLoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,011 of 2,23710%196 of 2085%1471694304934465
getAvailableBeForTask(long, long)1950%300%1616404011
getJob(String, String, boolean, PatternMatcher)1260%180%1010282811
checkPrivAndGetJob(String, String)1100%80%55191911
getAvailableBackendIds(long)1040%120%77232311
getMinTaskBeId(String)1030%120%77222211
createRoutineLoadJob(CreateRoutineLoadInfo, ConnectContext)940%40%33191911
pauseRoutineLoadJob(PauseRoutineLoadCommand)910%60%44212111
resumeRoutineLoadJob(ResumeRoutineLoadCommand)830%60%44232311
addRoutineLoadJob(RoutineLoadJob, String, String)810%40%33121211
checkPrivAndGetAllJobs(String)700%120%77171711
readFields(DataInput)66912%9110%56151801
cleanOverLimitRoutineLoadJobs()60811%8220%56202301
sortRoutineLoadJob(List)580%140%88151511
unprotectedRemoveJobFromDb(RoutineLoadJob)550%40%336611
getBeCurrentTasksNumMap()531825%5116%3471101
stopRoutineLoadJob(StopRoutineLoadCommand)520%n/a11121211
clearRoutineLoadJobIf(Predicate)511522%3125%23131901
getTagsFromReplicaAllocation(long, long)510%20%22111111
replayChangeRoutineLoadJob(RoutineLoadOperation)490%n/a11131311
alterRoutineLoadJob(AlterRoutineLoadCommand)440%40%33101011
isInBlacklist(long)380%40%338811
getJobByName(String)360%40%338811
unprotectedAddJob(RoutineLoadJob)340%n/a118811
isNameUsed(Long, String)340%40%339911
replayRemoveOldRoutineLoad(RoutineLoadOperation)240%20%227711
getSizeOfIdToRoutineLoadTask()220%20%225511
getRoutineLoadJobByMultiLoadTaskTxnId(long)210%20%224411
getJob(String, String)170%20%224411
checkTaskInJob(RoutineLoadTaskInfo)170%20%224411
replayCreateRoutineLoadJob(RoutineLoadJob)170%n/a115511
getClusterIdleSlotNum()153871%1375%1311001
replayAlterRoutineLoadJob(AlterRoutineLoadJobOperationLog)150%n/a114411
updateRoutineLoadJob()11945%3125%233501
addMultiLoadTaskTxnIdToRoutineLoadJobId(long, long)90%n/a112211
addToBlacklist(long)90%n/a112211
write(DataOutput)81463%1150%122501
getTotalMaxConcurrentTaskNum()80%n/a111111
lambda$getJob$8(RoutineLoadJob)80%20%221111
lambda$isNameUsed$7(RoutineLoadJob)80%20%221111
lambda$getActiveRoutineLoadJobs$0(RoutineLoadJob)80%20%221111
processTimeoutTasks()7956%1150%122401
getAllRoutineLoadJobs()70%n/a111111
getJob(long)70%n/a111111
lambda$getRoutineLoadJobByState$10(Set, RoutineLoadJob)50%n/a111111
lambda$getJob$9(PatternMatcher, RoutineLoadJob)50%n/a111111
lambda$isNameUsed$6(String, RoutineLoadJob)50%n/a111111
getAvailableBackendIdsForUt(long)40%n/a111111
cleanOldRoutineLoadJobs()3770%1150%121401
getBlacklist()30%n/a111111
lambda$cleanOverLimitRoutineLoadJobs$11(RoutineLoadJob)30%n/a111111
lambda$getTotalMaxConcurrentTaskNum$3(Integer)30%n/a111111
lambda$unprotectedAddJob$5(String)20%n/a111111
lambda$unprotectedAddJob$4(Long)20%n/a111111
RoutineLoadManager()28100%n/a010801
getRoutineLoadJobByState(Set)13100%n/a010301
updateBeIdToMaxConcurrentTasks()12100%n/a010301
getActiveRoutineLoadJobs()10100%n/a010301
removeMultiLoadTaskTxnIdToRoutineLoadJobId(long)7100%n/a010201
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
static {...}4100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$2(Long)3100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$1(Long)2100%n/a010101