getMinTaskBeId(String) |  | 0% |  | 0% | 7 | 7 | 22 | 22 | 1 | 1 |
checkPrivAndGetAllJobs(String) |  | 0% |  | 0% | 7 | 7 | 17 | 17 | 1 | 1 |
getAvailableBeForTask(long, long) |   | 65% |   | 56% | 12 | 16 | 11 | 40 | 0 | 1 |
cleanOverLimitRoutineLoadJobs() |   | 11% |   | 20% | 5 | 6 | 20 | 23 | 0 | 1 |
getAvailableBackendIds(long) |   | 43% |   | 50% | 6 | 7 | 10 | 23 | 0 | 1 |
getTagsFromReplicaAllocation(long, long) |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
getJobByName(String) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
addRoutineLoadJob(RoutineLoadJob, String, String) |   | 61% |   | 50% | 2 | 3 | 2 | 12 | 0 | 1 |
checkPrivAndGetJob(String, String) |   | 72% |   | 87% | 1 | 5 | 5 | 19 | 0 | 1 |
isInBlacklist(long) |   | 28% |   | 25% | 2 | 3 | 5 | 8 | 0 | 1 |
getSizeOfIdToRoutineLoadTask() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
pauseRoutineLoadJob(PauseRoutineLoadCommand) |   | 80% |   | 50% | 2 | 4 | 5 | 21 | 0 | 1 |
resumeRoutineLoadJob(ResumeRoutineLoadCommand) |   | 78% |   | 50% | 2 | 4 | 5 | 23 | 0 | 1 |
getJob(String, String, boolean, PatternMatcher) |   | 86% |   | 83% | 3 | 10 | 5 | 28 | 0 | 1 |
alterRoutineLoadJob(AlterRoutineLoadCommand) |   | 68% |   | 75% | 1 | 3 | 2 | 10 | 0 | 1 |
createRoutineLoadJob(CreateRoutineLoadInfo, ConnectContext) |   | 86% |   | 75% | 1 | 3 | 1 | 19 | 0 | 1 |
replayChangeRoutineLoadJob(RoutineLoadOperation) |   | 75% | | n/a | 0 | 1 | 3 | 13 | 0 | 1 |
addToBlacklist(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTotalMaxConcurrentTaskNum() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAvailableBackendIdsForUt(long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
cleanOldRoutineLoadJobs() |   | 70% |   | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
lambda$cleanOverLimitRoutineLoadJobs$11(RoutineLoadJob) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTotalMaxConcurrentTaskNum$3(Integer) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRoutineLoadJobByMultiLoadTaskTxnId(long) |   | 90% |   | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
checkTaskInJob(RoutineLoadTaskInfo) |   | 88% |   | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
lambda$isNameUsed$7(RoutineLoadJob) |   | 75% |   | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
sortRoutineLoadJob(List) |  | 98% |   | 85% | 2 | 8 | 1 | 15 | 0 | 1 |
getBeCurrentTasksNumMap() |  | 100% |  | 100% | 0 | 4 | 0 | 11 | 0 | 1 |
readFields(DataInput) |  | 100% |  | 100% | 0 | 5 | 0 | 16 | 0 | 1 |
clearRoutineLoadJobIf(Predicate) |  | 100% |  | 100% | 0 | 3 | 0 | 19 | 0 | 1 |
unprotectedRemoveJobFromDb(RoutineLoadJob) |  | 100% |  | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
getClusterIdleSlotNum() |  | 100% |  | 100% | 0 | 3 | 0 | 10 | 0 | 1 |
stopRoutineLoadJob(StopRoutineLoadCommand) |  | 100% | | n/a | 0 | 1 | 0 | 12 | 0 | 1 |
unprotectedAddJob(RoutineLoadJob) |  | 100% | | n/a | 0 | 1 | 0 | 8 | 0 | 1 |
isNameUsed(Long, String) |  | 100% |  | 100% | 0 | 3 | 0 | 9 | 0 | 1 |
RoutineLoadManager() |  | 100% | | n/a | 0 | 1 | 0 | 8 | 0 | 1 |
replayRemoveOldRoutineLoad(RoutineLoadOperation) |  | 100% |   | 50% | 1 | 2 | 0 | 7 | 0 | 1 |
write(DataOutput) |  | 100% |  | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
updateRoutineLoadJob() |  | 100% |  | 100% | 0 | 3 | 0 | 5 | 0 | 1 |
getJob(String, String) |  | 100% |  | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
replayCreateRoutineLoadJob(RoutineLoadJob) |  | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
processTimeoutTasks() |  | 100% |  | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
replayAlterRoutineLoadJob(AlterRoutineLoadJobOperationLog) |  | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
getRoutineLoadJobByState(Set) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
updateBeIdToMaxConcurrentTasks() |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
getActiveRoutineLoadJobs() |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
addMultiLoadTaskTxnIdToRoutineLoadJobId(long, long) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$getJob$8(RoutineLoadJob) |  | 100% |  | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
lambda$getActiveRoutineLoadJobs$0(RoutineLoadJob) |  | 100% |  | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
getAllRoutineLoadJobs() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
removeMultiLoadTaskTxnIdToRoutineLoadJobId(long) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
getJob(long) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
readLock() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
readUnlock() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
writeLock() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
writeUnlock() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$getRoutineLoadJobByState$10(Set, RoutineLoadJob) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getJob$9(PatternMatcher, RoutineLoadJob) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$isNameUsed$6(String, RoutineLoadJob) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
static {...} |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getBlacklist() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$updateBeIdToMaxConcurrentTasks$2(Long) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$unprotectedAddJob$5(String) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$unprotectedAddJob$4(Long) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$updateBeIdToMaxConcurrentTasks$1(Long) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |