| 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 | 
| 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 |