| cancelLoadJob(String, String, String, Expression) |  | 0% |  | 0% | 9 | 9 | 33 | 33 | 1 | 1 |
| replayUpdateJob(AbstractJob) |  | 0% |  | 0% | 7 | 7 | 20 | 20 | 1 | 1 |
| deleteStremingJob(AbstractJob) |   | 10% |   | 16% | 3 | 4 | 15 | 18 | 0 | 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 |
| 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 |
| getStreamingJobCnt() |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| getJobByNameOrNull(String) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 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 |
| getJobByName(String) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 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 |
| 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 |
| 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 |