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 |
createLoadJobFromStmt(LoadStmt) |  | 0% |  | 0% | 9 | 9 | 27 | 27 | 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 |
cancelLoadJob(CancelLoadStmt) |  | 0% |  | 0% | 5 | 5 | 24 | 24 | 1 | 1 |
createLoadJobFromStmt(InsertStmt) |  | 0% |  | 0% | 7 | 7 | 19 | 19 | 1 | 1 |
getAllLoadJobInfos() |  | 0% |  | 0% | 4 | 4 | 20 | 20 | 1 | 1 |
getLoadJobInfo(Load.JobInfo) |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
readFields(DataInput) |   | 27% |   | 25% | 5 | 7 | 16 | 24 | 0 | 1 |
lambda$addNeedCancelLoadJob$2(Expression, String, PatternMatcher, String, LoadJob) |  | 0% |  | 0% | 11 | 11 | 12 | 12 | 1 | 1 |
getLoadJobNum(JobState) |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
lambda$processEtlStateJobs$15(LoadJob) |  | 0% |  | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
createIngestionLoadJob(String, String, List, Map, UserIdentity) |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
replayEndLoadJob(LoadJobFinalOperation) |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
recordFinishedLoadJob(String, long, String, long, EtlJobType, long, String, String, UserIdentity, long) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
checkLabelUsed(long, String) |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
lambda$processLoadingStateJobs$17(LoadJob) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
getLoadJobNum(JobState, long) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 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 |
createLoadJobV1FromMultiStart(String, String) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
removeLoadJobIf(Predicate) |   | 57% |   | 25% | 2 | 3 | 6 | 16 | 0 | 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$processLoadingStateJobs$16(LoadJob) |  | 0% |  | 0% | 4 | 4 | 1 | 1 | 1 | 1 |
lambda$processEtlStateJobs$14(LoadJob) |  | 0% |  | 0% | 4 | 4 | 1 | 1 | 1 | 1 |
jobRemovedTrigger(LoadJob) |   | 72% |   | 50% | 6 | 7 | 5 | 16 | 0 | 1 |
lambda$queryLoadJobsByJobIds$18(List, Long) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$addNeedCancelLoadJob$5(CancelLoadStmt, String, PatternMatcher, String, LoadJob) |   | 80% |   | 75% | 5 | 11 | 1 | 12 | 0 | 1 |
cleanLabel(String, String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$unprotectedGetUnfinishedJobNum$0(LoadJob) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
analyzeLoadJobs() |   | 45% |   | 25% | 2 | 3 | 3 | 5 | 0 | 1 |
unprotectedGetUnfinishedJobNum() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
replayCleanLabel(CleanLabelOperationLog) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$checkLabelUsed$20(LoadJob) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$submitJobs$19(LoadJob) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getLoadJobNum$10(JobState, LoadJob) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getLoadJobNum$8(JobState, LoadJob) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$addNeedCancelLoadJob$1(LoadJob) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
getLoadJob(long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$cancelLoadJob$6(LoadJob) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$cancelLoadJob$3(LoadJob) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getLoadJobNum$11(LoadJob) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
initJobProgress(Long, TUniqueId, Set, List) |   | 64% |   | 50% | 1 | 2 | 1 | 4 | 0 | 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 |
lambda$removeOldLoadJob$12(long, LoadJob) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMysqlLoadManager() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getLoadJobNum$9(List) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getLoadJobNum$7(List) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$addNeedCancelLoadJob$4(LoadJob) |  | 87% |   | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
lambda$write$22(LoadJob) |  | 85% |   | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
addLoadJob(LoadJob) |  | 100% |   | 75% | 1 | 3 | 0 | 9 | 0 | 1 |
removeOverLimitLoadJob() |  | 100% |   | 75% | 2 | 5 | 0 | 17 | 0 | 1 |
write(DataOutput) |  | 100% |  | 100% | 0 | 2 | 0 | 11 | 0 | 1 |
addNeedCancelLoadJob(CancelLoadStmt, List, List) |  | 100% | | n/a | 0 | 1 | 0 | 10 | 0 | 1 |
LoadManager(LoadJobScheduler) |  | 100% | | n/a | 0 | 1 | 0 | 7 | 0 | 1 |
submitJobs() |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
getLoadJobNum() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
processEtlStateJobs() |  | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
processLoadingStateJobs() |  | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
lambda$write$21(long, LoadJob) |  | 100% |  | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
removeOldLoadJob() |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
prepareJobs() |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
writeLock() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
writeUnlock() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
start() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
static {...} |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$removeOverLimitLoadJob$13(LoadJob) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |