LoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,580 of 1,7459%194 of 2003%1441583684204458
getLoadJobInfosByDb(long, String, boolean, Set)1590%220%1212424211
cleanLabelInternal(long, String, boolean)1410%240%1313464611
getCreateLoadStmt(long, String)1250%80%55222211
cancelLoadJob(String, String, String, Expression)1070%80%55242411
createLoadJobFromCommand(LoadCommand, StmtExecutor, ConnectContext)970%100%66262611
getAllLoadJobInfos()820%60%44202011
lambda$addNeedCancelLoadJob$3(Expression, String, PatternMatcher, String, LoadJob)690%200%1111121211
readFields(DataInput)661619%9110%56152001
recordFinishedLoadJob(String, long, String, long, EtlJobType, long, String, String, String, UserIdentity, long)610%60%44121211
getLoadJobNum(JobState)610%40%33121211
addLoadJob(LoadJob)590%60%44101011
replayEndLoadJob(LoadJobFinalOperation)520%60%44111111
jobRemovedTrigger(LoadJob)490%100%66141411
removeOverLimitLoadJob()42816%6225%45151701
checkLabelUsed(long, String)410%60%44101011
getLoadJobNum(JobState, long)360%20%228811
addNeedCancelLoadJob(String, String, Expression, List, List)220%n/a118811
replayUpdateLoadJobStateInfo(LoadJob.LoadJobStateUpdateInfo)220%20%227711
removeLoadJobIf(Predicate)202757%3125%2361601
queryLoadJobsByJobIds(List)180%20%225511
replayCreateLoadJob(LoadJob)170%n/a113311
createLoadJob(LoadJob)170%40%336611
updateJobProgress(Long, Long, TUniqueId, TUniqueId, long, long, boolean)170%20%224411
lambda$unprotectedGetUnfinishedJobNum$1(LoadJob)160%60%443311
lambda$queryLoadJobsByJobIds$12(List, Long)150%20%223311
write(DataOutput)143068%1150%1231101
initJobProgress(Long, TUniqueId, Set, List)140%20%224411
cleanLabel(String, String)120%n/a113311
analyzeLoadJobs()11945%3125%233501
unprotectedGetUnfinishedJobNum()80%n/a113311
replayCleanLabel(CleanLabelOperationLog)80%n/a112211
lambda$write$15(long, LoadJob)80%20%221111
lambda$checkLabelUsed$14(LoadJob)80%20%221111
lambda$submitJobs$13(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
getLoadJob(long)70%n/a111111
lambda$cancelLoadJob$4(LoadJob)70%20%221111
lambda$getLoadJobNum$9(LoadJob)60%n/a111111
checkDb(String)50%n/a111111
readLock()50%n/a112211
readUnlock()50%n/a112211
lambda$removeOldLoadJob$10(long, LoadJob)40%n/a111111
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
lambda$createLoadJobFromCommand$0(WorkloadGroup)30%n/a111111
LoadManager(LoadJobScheduler)22100%n/a010701
submitJobs()13100%n/a010301
getLoadJobNum()10100%n/a010201
removeOldLoadJob()7100%n/a010301
prepareJobs()5100%n/a010301
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
start()4100%n/a010201
static {...}4100%n/a010101