RoutineLoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,237 of 2,2370%208 of 2080%1691694934936565
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
readFields(DataInput)750%100%66181811
getBeCurrentTasksNumMap()710%60%44111111
checkPrivAndGetAllJobs(String)700%120%77171711
cleanOverLimitRoutineLoadJobs()680%100%66232311
clearRoutineLoadJobIf(Predicate)660%40%33191911
sortRoutineLoadJob(List)580%140%88151511
unprotectedRemoveJobFromDb(RoutineLoadJob)550%40%336611
getClusterIdleSlotNum()530%40%33101011
stopRoutineLoadJob(StopRoutineLoadCommand)520%n/a11121211
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
RoutineLoadManager()280%n/a118811
replayRemoveOldRoutineLoad(RoutineLoadOperation)240%20%227711
getSizeOfIdToRoutineLoadTask()220%20%225511
write(DataOutput)220%20%225511
getRoutineLoadJobByMultiLoadTaskTxnId(long)210%20%224411
updateRoutineLoadJob()200%40%335511
getJob(String, String)170%20%224411
checkTaskInJob(RoutineLoadTaskInfo)170%20%224411
replayCreateRoutineLoadJob(RoutineLoadJob)170%n/a115511
processTimeoutTasks()160%20%224411
replayAlterRoutineLoadJob(AlterRoutineLoadJobOperationLog)150%n/a114411
getRoutineLoadJobByState(Set)130%n/a113311
updateBeIdToMaxConcurrentTasks()120%n/a113311
getActiveRoutineLoadJobs()100%n/a113311
cleanOldRoutineLoadJobs()100%20%224411
addMultiLoadTaskTxnIdToRoutineLoadJobId(long, long)90%n/a112211
addToBlacklist(long)90%n/a112211
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
getAllRoutineLoadJobs()70%n/a111111
removeMultiLoadTaskTxnIdToRoutineLoadJobId(long)70%n/a112211
getJob(long)70%n/a111111
readLock()50%n/a112211
readUnlock()50%n/a112211
writeLock()50%n/a112211
writeUnlock()50%n/a112211
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
static {...}40%n/a111111
getBlacklist()30%n/a111111
lambda$cleanOverLimitRoutineLoadJobs$11(RoutineLoadJob)30%n/a111111
lambda$getTotalMaxConcurrentTaskNum$3(Integer)30%n/a111111
lambda$updateBeIdToMaxConcurrentTasks$2(Long)30%n/a111111
lambda$unprotectedAddJob$5(String)20%n/a111111
lambda$unprotectedAddJob$4(Long)20%n/a111111
lambda$updateBeIdToMaxConcurrentTasks$1(Long)20%n/a111111