JobManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total953 of 1,36330%155 of 20022%1131552153222754
cancelLoadJob(String, String, String, Expression)1600%160%99333311
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
checkJobAuth(String, String, Set)620%80%55131311
alterJobStatus(String, JobStatus, FailureReason)530%60%44121211
replayUpdateJob(AbstractJob)424551%8433%5792001
cancelTaskById(String, Long)420%60%449911
validState(JobState, InsertJob)400%160%10106611
alterJob(AlterJobCommand)340%20%22111111
checkSameStatus(AbstractJob, JobStatus)300%80%557711
checkItsMatch(JobType, String, AbstractJob)300%80%555511
getStreamingJobCnt()240%40%336611
addNeedCancelLoadJob(String, String, CompoundPredicate.Operator, List, List)220%n/a118811
addNeedCancelLoadJob(String, String, Expression, List, List)220%n/a118811
unregisterJob(String, boolean)202555%3562%3571301
unregisterJob(Long)150%n/a114411
getJobByName(String)140%20%224411
dropJob(AbstractJob, String)130%20%224411
queryJobs(JobType, String)130%n/a112211
checkItsMatch(List, AbstractJob)130%20%223311
queryJobs(List)120%n/a112211
readFields(DataInput)93378%3562%251901
createJobInternal(AbstractJob, boolean)74586%11191%1711601
lambda$addNeedCancelLoadJob$7(InsertJob)70%20%221111
lambda$addNeedCancelLoadJob$5(InsertJob)70%20%221111
checkJobNameExist(String)6960%1150%121301
checkJobExist(Long)6753%1150%121301
lambda$write$4(DataOutput, Long, AbstractJob)6545%n/a012501
deleteStreamingJob(AbstractJob)6440%1150%123501
lambda$queryJobs$2(JobType, String, AbstractJob)60%n/a111111
readLock()50%n/a112211
readUnlock()50%n/a112211
lambda$queryJobs$3(List, AbstractJob)50%n/a111111
getStreamingTaskScheduler()30%n/a111111
dropJobInternal(AbstractJob, boolean)23694%21083%2711301
getJobByNameOrNull(String)22090%1375%131501
replayCreateJob(AbstractJob)888%1150%121401
replayDeleteJob(AbstractJob)888%1150%121401
alterJobStatus(Long, JobStatus)29100%2100%020601
triggerJob(long, Object)21100%n/a010401
JobManager()20100%n/a010401
start()19100%n/a010501
registerJob(AbstractJob)11100%n/a010401
queryJobs(JobType)11100%n/a010201
write(DataOutput)11100%n/a010301
getJob(long)7100%n/a010101
static {...}7100%n/a010201
getJob(Long)6100%n/a010101
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
lambda$queryJobs$1(JobType, AbstractJob)5100%n/a010101
lambda$checkJobNameExist$0(String, AbstractJob)5100%n/a010101
getStreamingTaskManager()3100%n/a010101