LoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total925 of 1,93152%122 of 21442%971722114611865
getCreateLoadStmt(long, String)1250%80%55222211
cleanLabelInternal(long, String, boolean)1113021%2314%1213374601
getAllLoadJobInfos()820%60%44202011
getLoadJobInfosByDb(long, String, boolean, Set)778251%13940%912204201
getLoadJobNum(JobState)610%40%33121211
createIngestionLoadJob(String, String, List, Map, UserIdentity)560%20%22121211
lambda$processEtlStateJobs$13(LoadJob)530%20%22121211
removeOverLimitLoadJob()42816%6225%45151701
lambda$addNeedCancelLoadJob$3(Expression, String, PatternMatcher, String, LoadJob)412840%14630%91161201
getLoadJobNum(JobState, long)360%20%228811
lambda$processLoadingStateJobs$15(LoadJob)350%20%229911
cancelLoadJob(String, String, String, Expression)347368%2675%2562401
createLoadJobFromCommand(LoadCommand, StmtExecutor, ConnectContext)296870%6440%5652601
checkLabelUsed(long, String)231843%3350%2461001
replayUpdateLoadJobStateInfo(LoadJob.LoadJobStateUpdateInfo)220%20%227711
getLoadJobNum()100%n/a112211
lambda$checkLabelUsed$18(LoadJob)80%20%221111
lambda$getLoadJobNum$8(JobState, LoadJob)80%20%221111
lambda$getLoadJobNum$6(JobState, LoadJob)80%20%221111
replayEndLoadJob(LoadJobFinalOperation)74586%3350%3431101
getLoadJob(long)70%n/a111111
lambda$processLoadingStateJobs$14(LoadJob)6650%3125%230101
lambda$processEtlStateJobs$12(LoadJob)6650%3125%230101
lambda$getLoadJobNum$9(LoadJob)60%n/a111111
readFields(DataInput)57793%1990%1612001
queryLoadJobsByJobIds(List)41477%1150%121501
getMysqlLoadManager()30%n/a111111
lambda$removeOverLimitLoadJob$11(LoadJob)30%n/a111111
lambda$getLoadJobNum$7(List)30%n/a111111
lambda$getLoadJobNum$5(List)30%n/a111111
jobRemovedTrigger(LoadJob)24795%2880%2621401
analyzeLoadJobs()21890%1375%131501
lambda$unprotectedGetUnfinishedJobNum$1(LoadJob)21487%1583%140301
lambda$submitJobs$17(LoadJob)2675%1150%120101
recordFinishedLoadJob(String, long, String, long, EtlJobType, long, String, String, String, UserIdentity, long)6098%2466%2411201
lambda$addNeedCancelLoadJob$2(LoadJob)787%1150%120101
lambda$cancelLoadJob$4(LoadJob)685%1150%120101
addLoadJob(LoadJob)59100%6100%0401001
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%2100%020401
lambda$queryLoadJobsByJobIds$16(List, Long)15100%1150%120301
initJobProgress(Long, TUniqueId, Set, List)14100%2100%020401
submitJobs()13100%n/a010301
cleanLabel(String, String)12100%n/a010301
processEtlStateJobs()9100%n/a010401
processLoadingStateJobs()9100%n/a010401
unprotectedGetUnfinishedJobNum()8100%n/a010301
replayCleanLabel(CleanLabelOperationLog)8100%n/a010201
lambda$write$19(long, LoadJob)8100%2100%020101
removeOldLoadJob()7100%n/a010301
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$10(long, LoadJob)4100%n/a010101
static {...}4100%n/a010101
lambda$createLoadJobFromCommand$0(WorkloadGroup)3100%n/a010101