readFields(DataInput) |  | 0% |  | 0% | 13 | 13 | 69 | 69 | 1 | 1 |
afterAborted(TransactionState, boolean, String) |   | 43% |   | 50% | 8 | 10 | 23 | 50 | 0 | 1 |
afterVisible(TransactionState, boolean) |  | 0% |  | 0% | 6 | 6 | 31 | 31 | 1 | 1 |
plan(NereidsStreamLoadPlanner, TUniqueId, long) |  | 0% |  | 0% | 8 | 8 | 36 | 36 | 1 | 1 |
getShowCreateInfo() |   | 73% |   | 45% | 12 | 13 | 9 | 55 | 0 | 1 |
setOptional(CreateRoutineLoadStmt) |   | 64% |   | 46% | 14 | 15 | 20 | 51 | 0 | 1 |
gsonPostProcess() |  | 0% |  | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
modifyCommonJobProperties(Map) |  | 0% |  | 0% | 7 | 7 | 19 | 19 | 1 | 1 |
RoutineLoadJob(Long, String, long, LoadDataSourceType, UserIdentity) |  | 0% |  | 0% | 2 | 2 | 18 | 18 | 1 | 1 |
updateNumOfData(long, long, long, long, long, boolean) |   | 80% |   | 59% | 8 | 12 | 12 | 51 | 0 | 1 |
read(DataInput) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 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 |
setCloudCluster(String) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 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 |
checkStateTransform(RoutineLoadJob.JobState) |   | 46% |   | 75% | 2 | 6 | 2 | 7 | 0 | 1 |
jobPropertiesToJsonString() |   | 81% |   | 50% | 8 | 9 | 1 | 29 | 0 | 1 |
setRoutineLoadDesc(RoutineLoadDesc) |   | 60% |   | 45% | 10 | 11 | 7 | 22 | 0 | 1 |
isExpired() |  | 0% |  | 0% | 4 | 4 | 4 | 4 | 1 | 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 |
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 |
setComputeGroup() |   | 70% |   | 75% | 2 | 5 | 5 | 20 | 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 |
containsTask(UUID) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getFormatType() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getColumnExprDescs() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$afterVisible$3(TransactionState, RoutineLoadTaskInfo) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$gsonPostProcess$14(String, String) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
hasSequenceCol() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
setCloudClusterById() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 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() |   | 96% |   | 50% | 1 | 2 | 1 | 30 | 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 |
setTypeRead(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMemtableOnSinkNode(boolean) |  | 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 |
update() |  | 98% |   | 72% | 5 | 10 | 0 | 55 | 0 | 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 |
getPartitions() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMergeType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDeleteCondition() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPrecedingFilter() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getWhereExpr() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getColumnSeparator() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLineDelimiter() | | 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 |
getQualifiedUser() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCloudCluster() | | 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 |
getCloudClusterId() | | 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 |
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 |
RoutineLoadJob(long, LoadDataSourceType) |  | 100% |  | 100% | 0 | 2 | 0 | 36 | 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 |
RoutineLoadJob(Long, String, long, long, LoadDataSourceType, UserIdentity) |  | 100% |  | 100% | 0 | 2 | 0 | 13 | 0 | 1 |
getBeCurrentTasksNumMap() |  | 100% |   | 75% | 1 | 3 | 0 | 9 | 0 | 1 |
appendProperties(StringBuilder, String, Object, boolean) |  | 100% |   | 83% | 1 | 4 | 0 | 7 | 0 | 1 |
processTimeoutTasks() |  | 100% |   | 75% | 1 | 3 | 0 | 9 | 0 | 1 |
setOtherMsg(String) |  | 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$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 |
setComment(String) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
executeRunning() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
setOrigStmt(OriginStatement) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 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 |
getUserIdentity() | | 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 |
isMultiTable() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getDataSourceType() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |