| getLoadJobInfosByDb(long, String, boolean, Set) |  | 0% | | 0% | 12 | 12 | 42 | 42 | 1 | 1 |
| cleanLabelInternal(long, String, boolean) | | 0% | | 0% | 13 | 13 | 46 | 46 | 1 | 1 |
| getCreateLoadStmt(long, String) | | 0% | | 0% | 5 | 5 | 22 | 22 | 1 | 1 |
| cancelLoadJob(String, String, String, Expression) | | 0% | | 0% | 5 | 5 | 24 | 24 | 1 | 1 |
| createLoadJobFromCommand(LoadCommand, StmtExecutor, ConnectContext) | | 0% | | 0% | 6 | 6 | 26 | 26 | 1 | 1 |
| getAllLoadJobInfos() | | 0% | | 0% | 4 | 4 | 20 | 20 | 1 | 1 |
| readFields(DataInput) | | 0% | | 0% | 6 | 6 | 20 | 20 | 1 | 1 |
| lambda$addNeedCancelLoadJob$3(Expression, String, PatternMatcher, String, LoadJob) | | 0% | | 0% | 11 | 11 | 12 | 12 | 1 | 1 |
| recordFinishedLoadJob(String, long, String, long, EtlJobType, long, String, String, String, UserIdentity, long) | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
| getLoadJobNum(JobState) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| addLoadJob(LoadJob) | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
| createIngestionLoadJob(String, String, List, Map, UserIdentity) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| lambda$processEtlStateJobs$13(LoadJob) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| replayEndLoadJob(LoadJobFinalOperation) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| removeOverLimitLoadJob() | | 0% | | 0% | 5 | 5 | 17 | 17 | 1 | 1 |
| jobRemovedTrigger(LoadJob) | | 0% | | 0% | 6 | 6 | 14 | 14 | 1 | 1 |
| removeLoadJobIf(Predicate) | | 0% | | 0% | 3 | 3 | 16 | 16 | 1 | 1 |
| write(DataOutput) | | 0% | | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
| checkLabelUsed(long, String) | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
| getLoadJobNum(JobState, long) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| lambda$processLoadingStateJobs$15(LoadJob) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| LoadManager(LoadJobScheduler) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| addNeedCancelLoadJob(String, String, Expression, List, List) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| replayUpdateLoadJobStateInfo(LoadJob.LoadJobStateUpdateInfo) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| analyzeLoadJobs() | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| queryLoadJobsByJobIds(List) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| replayCreateLoadJob(LoadJob) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| createLoadJob(LoadJob) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| updateJobProgress(Long, Long, TUniqueId, TUniqueId, long, long, boolean) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$unprotectedGetUnfinishedJobNum$1(LoadJob) | | 0% | | 0% | 4 | 4 | 3 | 3 | 1 | 1 |
| lambda$queryLoadJobsByJobIds$16(List, Long) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| initJobProgress(Long, TUniqueId, Set, List) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| submitJobs() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| cleanLabel(String, String) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$processLoadingStateJobs$14(LoadJob) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| lambda$processEtlStateJobs$12(LoadJob) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| getLoadJobNum() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| processEtlStateJobs() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| processLoadingStateJobs() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| unprotectedGetUnfinishedJobNum() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| replayCleanLabel(CleanLabelOperationLog) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$write$19(long, LoadJob) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$checkLabelUsed$18(LoadJob) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$submitJobs$17(LoadJob) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$getLoadJobNum$8(JobState, LoadJob) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$getLoadJobNum$6(JobState, LoadJob) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$addNeedCancelLoadJob$2(LoadJob) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| removeOldLoadJob() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getLoadJob(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$cancelLoadJob$4(LoadJob) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$getLoadJobNum$9(LoadJob) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| prepareJobs() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| checkDb(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| readLock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| readUnlock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| writeLock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| writeUnlock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| start() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$removeOldLoadJob$10(long, LoadJob) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getMysqlLoadManager() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$removeOverLimitLoadJob$11(LoadJob) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getLoadJobNum$7(List) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getLoadJobNum$5(List) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$createLoadJobFromCommand$0(WorkloadGroup) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |