| getTvfInfo() |  | 0% | | 0% | 9 | 9 | 27 | 27 | 1 | 1 |
| init() | | 0% | | n/a | 1 | 1 | 20 | 20 | 1 | 1 |
| beforeCommitted(TransactionState) | | 0% | | 0% | 3 | 3 | 20 | 20 | 1 | 1 |
| replayOnCloudMode() | | 0% | | 0% | 3 | 3 | 19 | 19 | 1 | 1 |
| gsonPostProcess() | | 0% | | 0% | 9 | 9 | 13 | 13 | 1 | 1 |
| updateJobStatisticAndOffset(StreamingTaskTxnCommitAttachment) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| createStreamingInsertTask() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| StreamingInsertJob(String, JobStatus, String, String, UserIdentity, JobExecutionConfiguration, Long, String, Map) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| generateEncryptedSql() | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| updateJobStatus(JobStatus) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| getCurrentTvf() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| fetchMeta() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| initLogicalPlan(boolean) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| onStreamTaskFail(StreamingInsertTask) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| replayOnUpdated(StreamingInsertJob) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| createTasks(TaskType, Map) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| onStreamTaskSuccess(StreamingInsertTask) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| queryTasks() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| replayOnCommitted(TransactionState) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| onTaskFail(StreamingJobSchedulerTask) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| makeConnectContext() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| isFinalStatus() | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| needScheduleTask() | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| afterCommitted(TransactionState, boolean) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| isReadyForScheduling(Map) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| writeUnlock() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| updateExecuteSql(String) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| clearRunningStreamTask() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| isJobRunning() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| write(DataOutput) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 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 |
| readLock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| readUnlock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| writeLock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| onReplayCreate() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| hasMoreDataToConsume() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setLatestAutoResumeTimestamp(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setAutoResumeCount(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setLastScheduleTaskTimestamp(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getShowInfo() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getFailureReason() | | 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 |
| getProperties() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTvfType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getRunningStreamTask() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getLastScheduleTaskTimestamp() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJobType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTaskMetaData() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| checkJobParamsInternal() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| beforeAborted(TransactionState) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| afterAborted(TransactionState, boolean, String) | | 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 |