JobManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,296 of 1,4309%192 of 2004%1471552963224754
cancelLoadJob(String, String, String, Expression)1670%160%99333311
replayUpdateJob(AbstractJob)870%120%77202011
lambda$addNeedCancelLoadJob$6(CompoundPredicate.Operator, String, PatternMatcher, String, InsertJob)700%200%1111121211
getLoadJobInfosByDb(long, String, String, boolean, JobState, String)690%80%55202011
lambda$addNeedCancelLoadJob$8(Expression, String, PatternMatcher, String, InsertJob)690%200%1111121211
createJobInternal(AbstractJob, boolean)580%120%77161611
unregisterJob(String, boolean)570%80%55131311
alterJobStatus(String, JobStatus, FailureReason)530%60%44121211
cancelTaskById(String, Long)480%60%449911
readFields(DataInput)420%80%559911
alterJob(AlterJobCommand)400%20%22111111
validState(JobState, InsertJob)400%160%10106611
dropJobInternal(AbstractJob, boolean)380%120%77131311
checkSameStatus(AbstractJob, JobStatus)300%80%557711
checkItsMatch(JobType, String, AbstractJob)300%80%555511
alterJobStatus(Long, JobStatus)290%20%226611
addNeedCancelLoadJob(String, String, CompoundPredicate.Operator, List, List)220%n/a118811
addNeedCancelLoadJob(String, String, Expression, List, List)220%n/a118811
checkJobNameExist(String)210%20%223311
triggerJob(long, Object)210%n/a114411
start()190%n/a115511
dropJob(AbstractJob, String)190%20%224411
checkJobExist(Long)190%20%223311
lambda$write$4(DataOutput, Long, AbstractJob)170%n/a115511
unregisterJob(Long)150%n/a114411
queryJobs(JobType, String)130%n/a112211
checkItsMatch(List, AbstractJob)130%20%223311
getStreamingJobCnt()121250%3125%233601
getJobByNameOrNull(String)121045%3125%233501
queryJobs(List)120%n/a112211
registerJob(AbstractJob)110%n/a114411
write(DataOutput)110%n/a113311
deleteStreamingJob(AbstractJob)100%20%225511
replayCreateJob(AbstractJob)90%20%224411
replayDeleteJob(AbstractJob)90%20%224411
getJob(long)70%n/a111111
lambda$addNeedCancelLoadJob$7(InsertJob)70%20%221111
lambda$addNeedCancelLoadJob$5(InsertJob)70%20%221111
checkJobAuth(String, String, Set)65690%3562%3531301
getJob(Long)60%n/a111111
lambda$queryJobs$2(JobType, String, AbstractJob)60%n/a111111
readLock()50%n/a112211
readUnlock()50%n/a112211
writeLock()50%n/a112211
writeUnlock()50%n/a112211
lambda$queryJobs$3(List, AbstractJob)50%n/a111111
lambda$queryJobs$1(JobType, AbstractJob)50%n/a111111
lambda$checkJobNameExist$0(String, AbstractJob)50%n/a111111
getStreamingTaskManager()30%n/a111111
getStreamingTaskScheduler()30%n/a111111
getJobByName(String)21890%1150%121401
JobManager()20100%n/a010401
queryJobs(JobType)11100%n/a010201
static {...}7100%n/a010201