LoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,030 of 1,74540%149 of 20025%1071582374202058
getCreateLoadStmt(long, String)1250%80%55222211
cleanLabelInternal(long, String, boolean)1113021%2314%1213374601
cancelLoadJob(String, String, String, Expression)832422%7112%45182401
getAllLoadJobInfos()820%60%44202011
getLoadJobInfosByDb(long, String, boolean, Set)778251%13940%912204201
lambda$addNeedCancelLoadJob$3(Expression, String, PatternMatcher, String, LoadJob)690%200%1111121211
getLoadJobNum(JobState)610%40%33121211
replayEndLoadJob(LoadJobFinalOperation)520%60%44111111
jobRemovedTrigger(LoadJob)490%100%66141411
removeOverLimitLoadJob()42816%6225%45151701
getLoadJobNum(JobState, long)360%20%228811
checkLabelUsed(long, String)34717%5116%3481001
createLoadJobFromCommand(LoadCommand, StmtExecutor, ConnectContext)296870%6440%5652601
recordFinishedLoadJob(String, long, String, long, EtlJobType, long, String, String, String, UserIdentity, long)243760%4233%3451201
addNeedCancelLoadJob(String, String, Expression, List, List)220%n/a118811
replayUpdateLoadJobStateInfo(LoadJob.LoadJobStateUpdateInfo)220%20%227711
queryLoadJobsByJobIds(List)180%20%225511
lambda$queryLoadJobsByJobIds$12(List, Long)150%20%223311
lambda$unprotectedGetUnfinishedJobNum$1(LoadJob)10637%5116%341301
removeLoadJobIf(Predicate)93880%1375%1331601
lambda$checkLabelUsed$14(LoadJob)80%20%221111
lambda$getLoadJobNum$8(JobState, LoadJob)80%20%221111
lambda$getLoadJobNum$6(JobState, LoadJob)80%20%221111
lambda$addNeedCancelLoadJob$2(LoadJob)80%20%221111
lambda$cancelLoadJob$4(LoadJob)70%20%221111
readFields(DataInput)57793%2880%2612001
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
analyzeLoadJobs()21890%1375%131501
lambda$submitJobs$13(LoadJob)2675%1150%120101
addLoadJob(LoadJob)59100%2466%2401001
write(DataOutput)44100%2100%0201101
LoadManager(LoadJobScheduler)22100%n/a010701
replayCreateLoadJob(LoadJob)17100%n/a010301
createLoadJob(LoadJob)17100%4100%030601
updateJobProgress(Long, Long, TUniqueId, TUniqueId, long, long, boolean)17100%1150%120401
initJobProgress(Long, TUniqueId, Set, List)14100%2100%020401
submitJobs()13100%n/a010301
cleanLabel(String, String)12100%n/a010301
getLoadJobNum()10100%n/a010201
unprotectedGetUnfinishedJobNum()8100%n/a010301
replayCleanLabel(CleanLabelOperationLog)8100%n/a010201
lambda$write$15(long, LoadJob)8100%2100%020101
removeOldLoadJob()7100%n/a010301
getLoadJob(long)7100%n/a010101
lambda$getLoadJobNum$9(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$10(long, LoadJob)4100%n/a010101
static {...}4100%n/a010101
lambda$createLoadJobFromCommand$0(WorkloadGroup)3100%n/a010101