| afterAborted(TransactionState, boolean, String) |   | 43% | | 50% | 8 | 10 | 23 | 50 | 0 | 1 |
| afterVisible(TransactionState, boolean) | | 0% | | 0% | 6 | 6 | 31 | 31 | 1 | 1 |
| getShowCreateInfo() | | 71% | | 45% | 12 | 13 | 12 | 58 | 0 | 1 |
| plan(NereidsStreamLoadPlanner, TUniqueId, long) | | 0% | | 0% | 8 | 8 | 29 | 29 | 1 | 1 |
| setOptional(CreateRoutineLoadInfo) | | 72% | | 43% | 16 | 17 | 17 | 61 | 0 | 1 |
| modifyCommonJobProperties(Map) | | 44% | | 40% | 11 | 12 | 19 | 34 | 0 | 1 |
| RoutineLoadJob(Long, String, long, LoadDataSourceType, UserIdentity) | | 0% | | 0% | 2 | 2 | 17 | 17 | 1 | 1 |
| jobPropertiesToJsonString() | | 74% | | 45% | 11 | 12 | 6 | 37 | 0 | 1 |
| updateNumOfData(long, long, long, long, long, boolean) | | 80% | | 59% | 8 | 12 | 12 | 51 | 0 | 1 |
| validateFlexiblePartialUpdateForAlter(Map, RoutineLoadDesc) | | 67% | | 73% | 8 | 16 | 7 | 34 | 0 | 1 |
| getShowStatistic() | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| replayOnAborted(TransactionState) | | 0% | | 0% | 5 | 5 | 8 | 8 | 1 | 1 |
| getTaskStatistic() | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| executeBeforeCheck(TransactionState, TransactionStatus) | | 34% | | 25% | 4 | 5 | 6 | 15 | 0 | 1 |
| lambda$getTasksShowInfo$6(List, RoutineLoadTaskInfo) | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
| executeTaskOnTxnStatusChanged(RoutineLoadTaskInfo, TransactionState, TransactionStatus, TransactionState.TxnStatusChangeReason) | | 53% | | 43% | 7 | 9 | 8 | 21 | 0 | 1 |
| isExpired() | | 0% | | 0% | 4 | 4 | 4 | 4 | 1 | 1 |
| update() | | 87% | | 61% | 6 | 10 | 6 | 55 | 0 | 1 |
| afterCommitted(TransactionState, boolean) | | 72% | | 50% | 3 | 5 | 5 | 24 | 0 | 1 |
| checkMeta(OlapTable, RoutineLoadDesc) | | 53% | | 60% | 4 | 6 | 5 | 15 | 0 | 1 |
| updateCloudProgress(RLTaskTxnCommitAttachment) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| getTasksShowInfo() | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| setComputeGroup() | | 55% | | 62% | 3 | 5 | 8 | 20 | 0 | 1 |
| lambda$gsonPostProcess$14(String, String) | | 25% | | 20% | 5 | 6 | 7 | 10 | 0 | 1 |
| replayOnCommitted(TransactionState) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| beforeAborted(TransactionState) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| replayUpdateProgress(RLTaskTxnCommitAttachment) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| checkStateTransform(RoutineLoadJob.JobState) | | 61% | | 80% | 1 | 4 | 1 | 5 | 0 | 1 |
| isAbnormalPause() | | 0% | | 0% | 4 | 4 | 2 | 2 | 1 | 1 |
| beforeCommitted(TransactionState) | | 34% | | 50% | 1 | 2 | 4 | 7 | 0 | 1 |
| getStateReason() | | 50% | | 28% | 4 | 5 | 2 | 4 | 0 | 1 |
| getEmptyFieldAsNull() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| containsTask(UUID) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| setCloudCluster() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| getFormatType() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| RoutineLoadJob(long, LoadDataSourceType) | | 91% | | 75% | 1 | 3 | 4 | 44 | 0 | 1 |
| RoutineLoadJob(Long, String, long, long, LoadDataSourceType, UserIdentity) | | 83% | | 75% | 1 | 3 | 4 | 18 | 0 | 1 |
| lambda$afterVisible$3(TransactionState, RoutineLoadTaskInfo) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| gsonPostProcess() | | 94% | | 62% | 6 | 9 | 3 | 41 | 0 | 1 |
| hasSequenceCol() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| read(DataInput) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| write(DataOutput) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$getTaskStatistic$13(RoutineLoadTaskInfo) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| getWorkloadGroup() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getShowCreateInfo$9(StringBuilder, String, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getShowInfo() | | 97% | | 50% | 1 | 2 | 1 | 31 | 0 | 1 |
| getCreateTimestampString() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getPauseTimestampString() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getEndTimestampString() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$containsTask$0(UUID, RoutineLoadTaskInfo) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| buildSeparator(String, String) | | 66% | | 25% | 2 | 3 | 1 | 3 | 0 | 1 |
| getColumnExprDescs() | | 60% | | 50% | 1 | 2 | 1 | 3 | 0 | 1 |
| setMemtableOnSinkNode(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setComment(String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setOrigStmt(OriginStatement) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setCloudCluster(String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| isFinal() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setMultiTable(boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getShowCreateInfo$11(Pair) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getShowCreateInfo$10(Pair) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isStrictMode() | | 76% | | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
| getPauseReason() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getRoutineLoadStatistic() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAuthCode() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getEndTimestamp() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJobStatistic() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getUserIdentity() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getEnclose() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getEscape() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getMaxBatchRows() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getMaxBatchSizeBytes() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getSendBatchParallelism() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isLoadToSingleTablet() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isFixedPartialUpdate() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isMemtableOnSinkNode() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getErrorLogUrls() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| totalProgress() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| totalLag() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getDataSourceType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getTaskStatistic$12(RoutineLoadTaskInfo) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTableName() | | 88% | | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
| getTimeout() | | 86% | | 50% | 1 | 2 | 0 | 4 | 0 | 1 |
| getTimezone() | | 83% | | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
| getFormat() | | 83% | | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
| getJsonPaths() | | 83% | | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
| getJsonRoot() | | 83% | | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
| getFileType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNegative() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTxnId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isReadJsonByLine() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getPath() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getHeaderType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getHiddenColumns() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| calculateCurrentConcurrentTaskNum() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| refreshKafkaPartitions(boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| unprotectNeedReschedule() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| needAutoResume() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateRoutineLoadDescForFlexiblePartialUpdate(RoutineLoadDesc) | | 98% | | 87% | 3 | 13 | 1 | 11 | 0 | 1 |
| lambda$afterAborted$4(TransactionState, RoutineLoadTaskInfo) | | 90% | | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
| lambda$afterCommitted$2(TransactionState, RoutineLoadTaskInfo) | | 90% | | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
| lambda$executeBeforeCheck$1(TransactionState, RoutineLoadTaskInfo) | | 90% | | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
| unprotectUpdateProgress() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setRoutineLoadDesc(RoutineLoadDesc) | | 100% | | 95% | 1 | 11 | 0 | 21 | 0 | 1 |
| unprotectUpdateState(RoutineLoadJob.JobState, ErrorReason, boolean) | | 100% | | 92% | 1 | 10 | 0 | 19 | 0 | 1 |
| updateState(RoutineLoadJob.JobState, ErrorReason, boolean) | | 100% | | n/a | 0 | 1 | 0 | 14 | 0 | 1 |
| getBeCurrentTasksNumMap() | | 100% | | 75% | 1 | 3 | 0 | 9 | 0 | 1 |
| syncSerializedSeparatorFields(Separator, boolean) | | 100% | | 100% | 0 | 6 | 0 | 6 | 0 | 1 |
| appendProperties(StringBuilder, String, Object, boolean) | | 100% | | 83% | 1 | 4 | 0 | 7 | 0 | 1 |
| processTimeoutTasks() | | 100% | | 75% | 1 | 3 | 0 | 9 | 0 | 1 |
| currentRoutineLoadDesc() | | 100% | | 100% | 0 | 2 | 0 | 2 | 0 | 1 |
| restoreSerializedSeparators() | | 100% | | 75% | 2 | 5 | 0 | 5 | 0 | 1 |
| setColumnDescsFromRoutineLoadDesc(RoutineLoadDesc) | | 100% | | 75% | 1 | 3 | 0 | 4 | 0 | 1 |
| setOtherMsg(String) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| gsonPreProcess() | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| updateProgress(RLTaskTxnCommitAttachment) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| executePause(ErrorReason) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
| executeCancel(ErrorReason) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
| getSizeOfRoutineLoadTaskInfoList() | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| executeNeedSchedule() | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| executeStop() | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| getDbFullName() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| isStripOuterArray() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| isNumAsString() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| isFuzzyParse() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$getShowCreateInfo$8(StringBuilder, String, String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| readLock() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| readUnlock() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| writeLock() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| writeUnlock() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| lambda$gsonPostProcess$15(CreateRoutineLoadInfo, Table) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$getShowCreateInfo$7(Database) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$getShowInfo$5(Database) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| executeRunning() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| getClusterInfo() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getId() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getName() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getDbId() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getTableId() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getState() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getPartitionNamesInfo() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getMergeType() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getUniqueKeyUpdateMode() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getDeleteCondition() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getPrecedingFilter() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getWhereExpr() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getColumnSeparator() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getLineDelimiter() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getMemLimit() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getProgress() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getMaxBatchIntervalS() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getSequenceCol() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getCloudCluster() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| isMultiTable() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |