| getTvfInfo() |  | 0% | | 0% | 14 | 14 | 37 | 37 | 1 | 1 |
| getShowSQL() | | 0% | | 0% | 7 | 7 | 23 | 23 | 1 | 1 |
| initInsertJob() | | 0% | | 0% | 4 | 4 | 20 | 20 | 1 | 1 |
| beforeCommitted(TransactionState) | | 0% | | 0% | 4 | 4 | 26 | 26 | 1 | 1 |
| cleanup() |  | 14% | | 20% | 5 | 6 | 20 | 25 | 0 | 1 |
| checkRequiredSourceProperties() | | 0% | | 0% | 8 | 8 | 10 | 10 | 1 | 1 |
| checkPrivilege(ConnectContext, String) | | 0% | | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
| replayOnCloudMode() | | 0% | | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
| hasPrivilege(UserIdentity) | | 0% | | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
| resetCloudProgress(Offset) | | 0% | | 0% | 3 | 3 | 18 | 18 | 1 | 1 |
| initSourceJob() | | 0% | | 0% | 2 | 2 | 17 | 17 | 1 | 1 |
| StreamingInsertJob(String, JobStatus, String, String, UserIdentity, JobExecutionConfiguration, Long, String, Map, String, DataSourceType, Map, Map) | | 0% | | n/a | 1 | 1 | 15 | 15 | 1 | 1 |
| resolveCloudCluster() | | 0% | | 0% | 5 | 5 | 20 | 20 | 1 | 1 |
| fetchMeta() | | 0% | | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
| createTableIfNotExists() | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| processTimeoutTasks() | | 0% | | 0% | 8 | 8 | 17 | 17 | 1 | 1 |
| StreamingInsertJob(String, JobStatus, String, String, UserIdentity, JobExecutionConfiguration, Long, String, Map) | | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| init() | | 0% | | n/a | 1 | 1 | 14 | 14 | 1 | 1 |
| alterJob(AlterJobCommand) | | 75% | | 75% | 5 | 11 | 11 | 44 | 0 | 1 |
| reportTaskFailure(TaskFailureRequest) | | 0% | | 0% | 6 | 6 | 13 | 13 | 1 | 1 |
| commitOffset(CommitOffsetRequest) | | 68% | | 57% | 6 | 8 | 9 | 29 | 0 | 1 |
| createStreamingTask() | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| resolveBoundBackend() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| getDbId() | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| updateJobStatisticAndOffset(CommitOffsetRequest) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| validateComputeGroupProperty(Map) | | 19% | | 25% | 4 | 5 | 10 | 12 | 0 | 1 |
| tryPauseJob(FailureReason) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| generateEncryptedSql() | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| gsonPostProcess() | | 65% | | 55% | 8 | 10 | 5 | 19 | 0 | 1 |
| checkHasSourceJobPriv(ConnectContext, String) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| replayOnUpdated(StreamingInsertJob) | | 80% | | 70% | 6 | 11 | 7 | 37 | 0 | 1 |
| createStreamingMultiTblTask() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getCurrentTvf() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| createStreamingInsertTask() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| queryAllStreamTasks() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| checkPrivilege(ConnectContext) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| updateJobStatisticAndOffset(StreamingTaskTxnCommitAttachment, boolean) | | 79% | | 50% | 4 | 6 | 4 | 19 | 0 | 1 |
| updateCloudJobStatisticAndOffset(StreamingTaskTxnCommitAttachment, boolean) | | 66% | | 33% | 3 | 4 | 4 | 14 | 0 | 1 |
| initLogicalPlan(boolean) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| updateNoTxnJobStatisticAndOffset(CommitOffsetRequest) | | 67% | | 50% | 2 | 3 | 4 | 13 | 0 | 1 |
| recordTasks(AbstractStreamingTask) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| validateOffset(String) | | 40% | | 50% | 2 | 3 | 4 | 8 | 0 | 1 |
| createTasks(TaskType, Map) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| checkPrivilege(ConnectContext, String, String) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| buildConvertedSourceProperties(Map) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| queryTasks() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| advanceSplitsIfNeed() | | 74% | | 90% | 1 | 6 | 4 | 18 | 0 | 1 |
| onTaskFail(StreamingJobSchedulerTask) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| replayOffsetProviderIfNeed() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| onStreamTaskSuccess(AbstractStreamingTask) | | 80% | | 75% | 1 | 3 | 3 | 21 | 0 | 1 |
| afterCommitted(TransactionState, boolean) | | 26% | | 50% | 1 | 2 | 5 | 8 | 0 | 1 |
| makeConnectContext() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| tryFinishJob() | | 66% | | 33% | 3 | 4 | 2 | 10 | 0 | 1 |
| getConvertedSourceProperties() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| onManualStatusAltered(JobStatus, FailureReason) | | 64% | | 33% | 3 | 4 | 3 | 10 | 0 | 1 |
| modifyPropertiesInternal(Map) | | 62% | | 50% | 1 | 2 | 2 | 7 | 0 | 1 |
| isReadyForScheduling(Map) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| onStreamTaskFail(AbstractStreamingTask) | | 75% | | 33% | 3 | 4 | 2 | 11 | 0 | 1 |
| createOffsetProvider(Map) | | 68% | | 50% | 1 | 2 | 1 | 6 | 0 | 1 |
| getProviderProps() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| needScheduleTask() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getLag() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| cancelAllTasks(boolean) | | 82% | | 50% | 3 | 5 | 0 | 10 | 0 | 1 |
| isJobRunning() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| write(DataOutput) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| isActive() | | 57% | | 25% | 2 | 3 | 0 | 1 | 0 | 1 |
| getOriginTvfProps() | | 50% | | 50% | 1 | 2 | 1 | 3 | 0 | 1 |
| onTaskSuccess(StreamingJobSchedulerTask) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| onRegister() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| formatMsgWhenExecuteQueueFull(Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| checkDataQuality(CommitOffsetRequest) | | 96% | | 83% | 2 | 7 | 2 | 31 | 0 | 1 |
| readLock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| readUnlock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| onReplayCreate() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| setLastScheduleTaskTimestamp(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setNeedRebuildReader(boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setSampleStartTime(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getMaxAutoResumeCount() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getShowInfo() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJobStatistic() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getLatestAutoResumeTimestamp() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAutoResumeCount() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getLastScheduleTaskTimestamp() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTargetDb() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getDataSourceType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getCloudCluster() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isNeedRebuildReader() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| clearRunningStreamTask(JobStatus) | | 93% | | 75% | 1 | 3 | 0 | 6 | 0 | 1 |
| getTaskMetaData() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| persistOffsetProviderIfNeed(JdbcSourceOffsetProvider, long) | | 95% | | 75% | 1 | 3 | 1 | 8 | 0 | 1 |
| getLagBytes() | | 88% | | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
| checkJobParamsInternal() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| replayOnAborted(TransactionState) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| afterVisible(TransactionState, boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| replayOnVisible(TransactionState) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| updateJobStatus(JobStatus) | | 100% | | 87% | 1 | 5 | 0 | 13 | 0 | 1 |
| recomputeDerivedFields() | | 100% | | 83% | 1 | 4 | 0 | 11 | 0 | 1 |
| StreamingInsertJob() | | 100% | | n/a | 0 | 1 | 0 | 9 | 0 | 1 |
| prepareSchemaChangeResume(JobStatus) | | 100% | | 90% | 1 | 6 | 0 | 6 | 0 | 1 |
| updateJobStatusIfCurrent(JobStatus, JobStatus) | | 100% | | 100% | 0 | 2 | 0 | 6 | 0 | 1 |
| validateAlterOffset(String) | | 100% | | 50% | 1 | 2 | 0 | 7 | 0 | 1 |
| replayOnCommitted(TransactionState) | | 100% | | n/a | 0 | 1 | 0 | 6 | 0 | 1 |
| resetFailureInfo(FailureReason) | | 100% | | 50% | 1 | 2 | 0 | 6 | 0 | 1 |
| isFinalStatus() | | 100% | | 100% | 0 | 3 | 0 | 1 | 0 | 1 |
| hasReachedEnd() | | 100% | | 75% | 1 | 3 | 0 | 1 | 0 | 1 |
| writeUnlock() | | 100% | | 100% | 0 | 2 | 0 | 3 | 0 | 1 |
| getLastSourceEventTimestampSeconds() | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| getLagMessages() | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| closeOffsetProvider() | | 100% | | 50% | 1 | 2 | 0 | 3 | 0 | 1 |
| writeLock() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| getLastTaskSuccessTimeSeconds() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| hasMoreDataToConsume() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getId() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setNonTxnJobStatistic(StreamingJobStatistic) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setFailureReason(FailureReason) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setLatestAutoResumeTimestamp(long) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setAutoResumeCount(long) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setOffsetProviderPersist(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setJobRuntimeMsg(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getNonTxnJobStatistic() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getFailureReason() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getProperties() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getTvfType() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getRunningStreamTask() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getOffsetProviderPersist() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getJobRuntimeMsg() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getSourceProperties() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getTargetProperties() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getSyncTables() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| isTolerateSchemaChange() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getJobType() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| beforeAborted(TransactionState) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| afterAborted(TransactionState, boolean, String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |