LoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total702 of 2,01065%89 of 21758%721761554831167
getCreateLoadStmt(long, String)992620%7112%45172201
createLoadJobFromStmt(LoadStmt)950%100%66262611
getAllLoadJobInfos()820%60%44202011
getLoadJobNum(JobState)610%40%33121211
createIngestionLoadJob(String, String, List, Map, UserIdentity)560%20%22121211
lambda$processEtlStateJobs$14(LoadJob)530%20%22121211
lambda$addNeedCancelLoadJob$4(Expression, String, PatternMatcher, String, LoadJob)412840%14630%91161201
lambda$processLoadingStateJobs$16(LoadJob)350%20%229911
cancelLoadJob(String, String, String, Expression)297872%1787%1552401
createLoadJobFromCommand(LoadCommand, StmtExecutor, ConnectContext)296870%6440%5652601
checkLabelUsed(long, String)231843%3350%2461001
replayUpdateLoadJobStateInfo(LoadJob.LoadJobStateUpdateInfo)220%20%227711
getLoadJobInfosByDb(long, String, boolean, Set)1014993%12195%11244201
cleanLabelInternal(long, String, boolean)1013192%51979%51354601
lambda$checkLabelUsed$19(LoadJob)80%20%221111
lambda$getLoadJobNum$9(JobState, LoadJob)80%20%221111
replayEndLoadJob(LoadJobFinalOperation)74586%3350%3431101
lambda$processLoadingStateJobs$15(LoadJob)6650%3125%230101
lambda$processEtlStateJobs$13(LoadJob)6650%3125%230101
getLoadJobNum(JobState, long)43288%1150%121801
queryLoadJobsByJobIds(List)41477%1150%121501
lambda$getLoadJobNum$8(List)30%n/a111111
lambda$createLoadJobFromStmt$1(WorkloadGroup)30%n/a111111
jobRemovedTrigger(LoadJob)24795%2880%2621401
analyzeLoadJobs()21890%1375%131501
lambda$submitJobs$18(LoadJob)2675%1150%120101
recordFinishedLoadJob(String, long, String, long, EtlJobType, long, String, String, UserIdentity, long)4897%1266%1311101
lambda$cancelLoadJob$5(LoadJob)685%1150%120101
readFields(DataInput)82100%10100%0602001
addLoadJob(LoadJob)56100%4100%030901
removeOverLimitLoadJob()50100%2675%2501701
removeLoadJobIf(Predicate)47100%4100%0301601
write(DataOutput)44100%2100%0201101
LoadManager(LoadJobScheduler)22100%n/a010701
addNeedCancelLoadJob(String, String, Expression, List, List)22100%n/a010801
replayCreateLoadJob(LoadJob)17100%n/a010301
createLoadJob(LoadJob)17100%4100%030601
updateJobProgress(Long, Long, TUniqueId, TUniqueId, long, long, boolean)17100%1150%120401
lambda$queryLoadJobsByJobIds$17(List, Long)15100%2100%020301
initJobProgress(Long, TUniqueId, Set, List)14100%2100%020401
submitJobs()13100%n/a010301
cleanLabel(String, String)12100%n/a010301
lambda$unprotectedGetUnfinishedJobNum$2(LoadJob)12100%4100%030101
getLoadJobNum()10100%n/a010201
processEtlStateJobs()9100%n/a010401
processLoadingStateJobs()9100%n/a010401
unprotectedGetUnfinishedJobNum()8100%n/a010201
replayCleanLabel(CleanLabelOperationLog)8100%n/a010201
lambda$write$20(long, LoadJob)8100%2100%020101
lambda$getLoadJobNum$7(JobState, LoadJob)8100%2100%020101
lambda$addNeedCancelLoadJob$3(LoadJob)8100%2100%020101
removeOldLoadJob()7100%n/a010301
getLoadJob(long)7100%n/a010101
lambda$getLoadJobNum$10(LoadJob)6100%n/a010101
prepareJobs()5100%n/a010301
checkDb(String)5100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
start()4100%n/a010201
lambda$removeOldLoadJob$11(long, LoadJob)4100%n/a010101
static {...}4100%n/a010101
getMysqlLoadManager()3100%n/a010101
lambda$removeOverLimitLoadJob$12(LoadJob)3100%n/a010101
lambda$getLoadJobNum$6(List)3100%n/a010101
lambda$createLoadJobFromCommand$0(WorkloadGroup)3100%n/a010101