LoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,935 of 2,40119%235 of 27715%1762124305554873
getLoadJobInfosByDb(long, String, boolean, Set)1590%220%1212424211
cleanLabelInternal(long, String, boolean)1410%240%1313464611
createLoadJobFromStmt(LoadStmt)1200%160%99272711
getCreateLoadStmt(long, String)1180%80%55222211
cancelLoadJob(String, String, String, Expression)1070%80%55242411
cancelLoadJob(CancelLoadStmt)1060%80%55242411
createLoadJobFromStmt(InsertStmt)990%120%77191911
getAllLoadJobInfos()820%60%44202011
getLoadJobInfo(Load.JobInfo)780%60%44141411
readFields(DataInput)702627%9325%57162401
lambda$addNeedCancelLoadJob$2(Expression, String, PatternMatcher, String, LoadJob)690%200%1111121211
getLoadJobNum(JobState)610%40%33121211
lambda$processEtlStateJobs$15(LoadJob)600%40%33141411
createIngestionLoadJob(String, String, List, Map, UserIdentity)560%20%22121211
replayEndLoadJob(LoadJobFinalOperation)520%60%44111111
recordFinishedLoadJob(String, long, String, long, EtlJobType, long, String, String, UserIdentity, long)490%30%33111111
checkLabelUsed(long, String)470%60%44111111
lambda$processLoadingStateJobs$17(LoadJob)420%40%33111111
getLoadJobNum(JobState, long)360%20%228811
addNeedCancelLoadJob(String, String, Expression, List, List)220%n/a118811
replayUpdateLoadJobStateInfo(LoadJob.LoadJobStateUpdateInfo)220%20%227711
createLoadJobV1FromMultiStart(String, String)210%n/a117711
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$processLoadingStateJobs$16(LoadJob)160%60%441111
lambda$processEtlStateJobs$14(LoadJob)160%60%441111
jobRemovedTrigger(LoadJob)154072%6650%6751601
lambda$queryLoadJobsByJobIds$18(List, Long)150%20%223311
lambda$addNeedCancelLoadJob$5(CancelLoadStmt, String, PatternMatcher, String, LoadJob)145880%51575%51111201
cleanLabel(String, String)120%n/a113311
lambda$unprotectedGetUnfinishedJobNum$0(LoadJob)120%40%331111
analyzeLoadJobs()11945%3125%233501
unprotectedGetUnfinishedJobNum()80%n/a112211
replayCleanLabel(CleanLabelOperationLog)80%n/a112211
lambda$checkLabelUsed$20(LoadJob)80%20%221111
lambda$submitJobs$19(LoadJob)80%20%221111
lambda$getLoadJobNum$10(JobState, LoadJob)80%20%221111
lambda$getLoadJobNum$8(JobState, LoadJob)80%20%221111
lambda$addNeedCancelLoadJob$1(LoadJob)80%20%221111
getLoadJob(long)70%n/a111111
lambda$cancelLoadJob$6(LoadJob)70%20%221111
lambda$cancelLoadJob$3(LoadJob)70%20%221111
lambda$getLoadJobNum$11(LoadJob)60%n/a111111
initJobProgress(Long, TUniqueId, Set, List)5964%1150%121401
checkDb(String)50%n/a111111
readLock()50%n/a112211
readUnlock()50%n/a112211
lambda$removeOldLoadJob$12(long, LoadJob)40%n/a111111
getMysqlLoadManager()30%n/a111111
lambda$getLoadJobNum$9(List)30%n/a111111
lambda$getLoadJobNum$7(List)30%n/a111111
lambda$addNeedCancelLoadJob$4(LoadJob)787%1150%120101
lambda$write$22(LoadJob)685%1150%120101
addLoadJob(LoadJob)56100%1375%130901
removeOverLimitLoadJob()50100%2675%2501701
write(DataOutput)46100%2100%0201101
addNeedCancelLoadJob(CancelLoadStmt, List, List)28100%n/a0101001
LoadManager(LoadJobScheduler)22100%n/a010701
submitJobs()13100%n/a010301
getLoadJobNum()10100%n/a010201
processEtlStateJobs()9100%n/a010401
processLoadingStateJobs()9100%n/a010401
lambda$write$21(long, LoadJob)8100%2100%020101
removeOldLoadJob()7100%n/a010301
prepareJobs()5100%n/a010301
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
start()4100%n/a010201
static {...}4100%n/a010101
lambda$removeOverLimitLoadJob$13(LoadJob)3100%n/a010101