| cancelLoadJob(String, String, String, Expression) |   | 0% |   | 0% | 9 | 9 | 33 | 33 | 1 | 1 | 
| replayUpdateJob(AbstractJob) |   | 0% |   | 0% | 7 | 7 | 20 | 20 | 1 | 1 | 
| lambda$addNeedCancelLoadJob$6(CompoundPredicate.Operator, String, PatternMatcher, String, InsertJob) |   | 0% |   | 0% | 11 | 11 | 12 | 12 | 1 | 1 | 
| getLoadJobInfosByDb(long, String, String, boolean, JobState, String) |   | 0% |   | 0% | 5 | 5 | 20 | 20 | 1 | 1 | 
| lambda$addNeedCancelLoadJob$8(Expression, String, PatternMatcher, String, InsertJob) |   | 0% |   | 0% | 11 | 11 | 12 | 12 | 1 | 1 | 
| deleteStremingJob(AbstractJob) |    | 4% |    | 16% | 3 | 4 | 16 | 18 | 0 | 1 | 
| unregisterJob(String, boolean) |   | 0% |   | 0% | 5 | 5 | 13 | 13 | 1 | 1 | 
| cancelTaskById(String, Long) |   | 0% |   | 0% | 4 | 4 | 9 | 9 | 1 | 1 | 
| alterJobStatus(String, JobStatus) |   | 0% |   | 0% | 3 | 3 | 10 | 10 | 1 | 1 | 
| alterJob(AlterJobCommand) |   | 0% |   | 0% | 2 | 2 | 11 | 11 | 1 | 1 | 
| validState(JobState, InsertJob) |   | 0% |   | 0% | 10 | 10 | 6 | 6 | 1 | 1 | 
| checkSameStatus(AbstractJob, JobStatus) |   | 0% |   | 0% | 5 | 5 | 7 | 7 | 1 | 1 | 
| checkItsMatch(JobType, String, AbstractJob) |   | 0% |   | 0% | 5 | 5 | 5 | 5 | 1 | 1 | 
| readFields(DataInput) |   | 0% |   | 0% | 3 | 3 | 7 | 7 | 1 | 1 | 
| alterJobStatus(Long, JobStatus) |   | 0% |   | 0% | 2 | 2 | 6 | 6 | 1 | 1 | 
| addNeedCancelLoadJob(String, String, CompoundPredicate.Operator, List, List) |   | 0% |  | n/a | 1 | 1 | 8 | 8 | 1 | 1 | 
| addNeedCancelLoadJob(String, String, Expression, List, List) |   | 0% |  | n/a | 1 | 1 | 8 | 8 | 1 | 1 | 
| dropJob(AbstractJob, String) |   | 0% |   | 0% | 2 | 2 | 4 | 4 | 1 | 1 | 
| createJobInternal(AbstractJob, boolean) |    | 70% |    | 50% | 6 | 7 | 3 | 16 | 0 | 1 | 
| lambda$write$4(DataOutput, Long, AbstractJob) |   | 0% |  | n/a | 1 | 1 | 5 | 5 | 1 | 1 | 
| unregisterJob(Long) |   | 0% |  | n/a | 1 | 1 | 4 | 4 | 1 | 1 | 
| queryJobs(JobType, String) |   | 0% |  | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 
| checkItsMatch(List, AbstractJob) |   | 0% |   | 0% | 2 | 2 | 3 | 3 | 1 | 1 | 
| getStreamingJobCnt() |    | 50% |    | 25% | 2 | 3 | 3 | 6 | 0 | 1 | 
| getJobByNameOrNull(String) |    | 45% |    | 25% | 2 | 3 | 3 | 5 | 0 | 1 | 
| checkJobNameExist(String) |    | 42% |    | 50% | 1 | 2 | 1 | 3 | 0 | 1 | 
| checkJobExist(Long) |    | 36% |    | 50% | 1 | 2 | 1 | 3 | 0 | 1 | 
| queryJobs(List) |   | 0% |  | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 
| registerJob(AbstractJob) |   | 0% |  | n/a | 1 | 1 | 4 | 4 | 1 | 1 | 
| write(DataOutput) |   | 0% |  | n/a | 1 | 1 | 3 | 3 | 1 | 1 | 
| replayCreateJob(AbstractJob) |   | 0% |   | 0% | 2 | 2 | 4 | 4 | 1 | 1 | 
| replayDeleteJob(AbstractJob) |   | 0% |   | 0% | 2 | 2 | 4 | 4 | 1 | 1 | 
| lambda$addNeedCancelLoadJob$7(InsertJob) |   | 0% |   | 0% | 2 | 2 | 1 | 1 | 1 | 1 | 
| lambda$addNeedCancelLoadJob$5(InsertJob) |   | 0% |   | 0% | 2 | 2 | 1 | 1 | 1 | 1 | 
| checkJobAuth(String, String, Set) |    | 90% |    | 62% | 3 | 5 | 3 | 13 | 0 | 1 | 
| lambda$queryJobs$2(JobType, String, AbstractJob) |   | 0% |  | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 
| dropJobInternal(AbstractJob, boolean) |    | 86% |    | 50% | 5 | 6 | 2 | 12 | 0 | 1 | 
| readLock() |   | 0% |  | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 
| readUnlock() |   | 0% |  | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 
| lambda$queryJobs$3(List, AbstractJob) |   | 0% |  | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 
| lambda$queryJobs$1(JobType, AbstractJob) |   | 0% |  | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 
| getStreamingTaskScheduler() |   | 0% |  | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 
| getJobByName(String) |    | 90% |    | 50% | 1 | 2 | 1 | 4 | 0 | 1 | 
| triggerJob(long, Object) |   | 100% |  | n/a | 0 | 1 | 0 | 4 | 0 | 1 | 
| JobManager() |   | 100% |  | n/a | 0 | 1 | 0 | 4 | 0 | 1 | 
| start() |   | 100% |  | n/a | 0 | 1 | 0 | 5 | 0 | 1 | 
| queryJobs(JobType) |   | 100% |  | n/a | 0 | 1 | 0 | 2 | 0 | 1 | 
| getJob(long) |   | 100% |  | n/a | 0 | 1 | 0 | 1 | 0 | 1 | 
| static {...} |   | 100% |  | n/a | 0 | 1 | 0 | 2 | 0 | 1 | 
| getJob(Long) |   | 100% |  | n/a | 0 | 1 | 0 | 1 | 0 | 1 | 
| writeLock() |   | 100% |  | n/a | 0 | 1 | 0 | 2 | 0 | 1 | 
| writeUnlock() |   | 100% |  | n/a | 0 | 1 | 0 | 2 | 0 | 1 | 
| lambda$checkJobNameExist$0(String, AbstractJob) |   | 100% |  | n/a | 0 | 1 | 0 | 1 | 0 | 1 | 
| getStreamingTaskManager() |   | 100% |  | n/a | 0 | 1 | 0 | 1 | 0 | 1 |