RoutineLoadJob

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,112 of 4,42652%237 of 38538%24634346499779146
readFields(DataInput)3060%240%1313696911
afterAborted(TransactionState, boolean, String)14311143%8850%810235001
afterVisible(TransactionState, boolean)1330%100%66313111
plan(NereidsStreamLoadPlanner, TUniqueId, long)1280%140%88363611
getShowCreateInfo()9926873%131145%121395501
setOptional(CreateRoutineLoadStmt)9216664%151346%1415205101
gsonPostProcess()710%40%33151511
modifyCommonJobProperties(Map)670%120%77191911
RoutineLoadJob(Long, String, long, LoadDataSourceType, UserIdentity)610%20%22181811
updateNumOfData(long, long, long, long, long, boolean)5422980%91359%812125101
read(DataInput)450%40%33101011
getShowStatistic()410%n/a118811
replayOnAborted(TransactionState)400%80%558811
getTaskStatistic()400%n/a119911
executeBeforeCheck(TransactionState, TransactionStatus)382034%6225%4561501
setCloudCluster(String)380%40%339911
lambda$getTasksShowInfo$6(List, RoutineLoadTaskInfo)370%60%44101011
executeTaskOnTxnStatusChanged(RoutineLoadTaskInfo, TransactionState, TransactionStatus, TransactionState.TxnStatusChangeReason)364153%9743%7982101
checkStateTransform(RoutineLoadJob.JobState)343046%2675%262701
jobPropertiesToJsonString()3314781%8850%8912901
setRoutineLoadDesc(RoutineLoadDesc)314860%11945%101172201
isExpired()310%60%444411
afterCommitted(TransactionState, boolean)307872%4450%3552401
checkMeta(OlapTable, RoutineLoadDesc)293353%4660%4651501
updateCloudProgress(RLTaskTxnCommitAttachment)280%n/a116611
getTasksShowInfo()280%40%337711
replayOnCommitted(TransactionState)250%20%226611
beforeAborted(TransactionState)230%20%227711
replayUpdateProgress(RLTaskTxnCommitAttachment)200%n/a116611
setComputeGroup()184370%2675%2552001
isAbnormalPause()160%60%442211
beforeCommitted(TransactionState)15834%1150%124701
getStateReason()131350%5228%452401
containsTask(UUID)130%n/a114411
getFormatType()110%20%224411
getColumnExprDescs()100%20%223311
lambda$afterVisible$3(TransactionState, RoutineLoadTaskInfo)100%20%221111
lambda$gsonPostProcess$14(String, String)90%20%223311
hasSequenceCol()80%20%221111
setCloudClusterById()80%n/a113311
write(DataOutput)70%n/a112211
lambda$getTaskStatistic$13(RoutineLoadTaskInfo)70%20%221111
getWorkloadGroup()60%n/a111111
lambda$getShowCreateInfo$9(StringBuilder, String, String)60%n/a111111
getShowInfo()516196%1150%1213001
getCreateTimestampString()50%n/a111111
getPauseTimestampString()50%n/a111111
getEndTimestampString()50%n/a111111
lambda$containsTask$0(UUID, RoutineLoadTaskInfo)50%n/a111111
setTypeRead(boolean)40%n/a112211
setMemtableOnSinkNode(boolean)40%n/a112211
isFinal()40%n/a111111
setMultiTable(boolean)40%n/a111111
lambda$getShowCreateInfo$11(Pair)40%n/a111111
lambda$getShowCreateInfo$10(Pair)40%n/a111111
update()23098%51372%51005501
isStrictMode()1076%1150%121401
getPauseReason()0%n/a111111
getRoutineLoadStatistic()0%n/a111111
getAuthCode()0%n/a111111
getEndTimestamp()0%n/a111111
getJobStatistic()0%n/a111111
getPartitions()0%n/a111111
getMergeType()0%n/a111111
getDeleteCondition()0%n/a111111
getPrecedingFilter()0%n/a111111
getWhereExpr()0%n/a111111
getColumnSeparator()0%n/a111111
getLineDelimiter()0%n/a111111
getEnclose()0%n/a111111
getEscape()0%n/a111111
getMaxBatchRows()0%n/a111111
getMaxBatchSizeBytes()0%n/a111111
getSendBatchParallelism()0%n/a111111
isLoadToSingleTablet()0%n/a111111
isFixedPartialUpdate()0%n/a111111
isMemtableOnSinkNode()0%n/a111111
getQualifiedUser()0%n/a111111
getCloudCluster()0%n/a111111
getErrorLogUrls()0%n/a111111
totalProgress()0%n/a111111
totalLag()0%n/a111111
getCloudClusterId()0%n/a111111
lambda$getTaskStatistic$12(RoutineLoadTaskInfo)0%n/a111111
getTableName()1688%1150%121401
getTimeout()1386%1150%120401
getTimezone()1083%1150%121401
getFormat()1083%1150%121401
getJsonPaths()1083%1150%121401
getJsonRoot()1083%1150%121401
getFileType()0%n/a111111
getNegative()0%n/a111111
getTxnId()0%n/a111111
isReadJsonByLine()0%n/a111111
getPath()0%n/a111111
getHeaderType()0%n/a111111
getHiddenColumns()0%n/a111111
calculateCurrentConcurrentTaskNum()0%n/a111111
refreshKafkaPartitions(boolean)0%n/a111111
unprotectNeedReschedule()0%n/a111111
needAutoResume()0%n/a111111
lambda$afterAborted$4(TransactionState, RoutineLoadTaskInfo)990%1150%120101
lambda$afterCommitted$2(TransactionState, RoutineLoadTaskInfo)990%1150%120101
lambda$executeBeforeCheck$1(TransactionState, RoutineLoadTaskInfo)990%1150%120101
unprotectUpdateProgress()0%n/a111111
RoutineLoadJob(long, LoadDataSourceType)103100%2100%0203601
unprotectUpdateState(RoutineLoadJob.JobState, ErrorReason, boolean)63100%11392%11001901
updateState(RoutineLoadJob.JobState, ErrorReason, boolean)51100%n/a0101401
RoutineLoadJob(Long, String, long, long, LoadDataSourceType, UserIdentity)47100%2100%0201301
getBeCurrentTasksNumMap()46100%1375%130901
appendProperties(StringBuilder, String, Object, boolean)35100%1583%140701
processTimeoutTasks()33100%1375%130901
setOtherMsg(String)18100%n/a010401
updateProgress(RLTaskTxnCommitAttachment)14100%n/a010301
executePause(ErrorReason)13100%n/a010501
executeCancel(ErrorReason)13100%n/a010501
getSizeOfRoutineLoadTaskInfoList()10100%n/a010301
executeNeedSchedule()10100%n/a010401
executeStop()10100%n/a010401
getDbFullName()7100%n/a010101
isStripOuterArray()7100%n/a010101
isNumAsString()7100%n/a010101
isFuzzyParse()7100%n/a010101
lambda$getShowCreateInfo$8(StringBuilder, String, String)6100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
lambda$getShowCreateInfo$7(Database)5100%n/a010101
lambda$getShowInfo$5(Database)5100%n/a010101
setComment(String)4100%n/a010201
executeRunning()4100%n/a010201
setOrigStmt(OriginStatement)4100%n/a010201
static {...}4100%n/a010101
getId()100%n/a010101
getName()100%n/a010101
getDbId()100%n/a010101
getTableId()100%n/a010101
getState()100%n/a010101
getUserIdentity()100%n/a010101
getMemLimit()100%n/a010101
getProgress()100%n/a010101
getMaxBatchIntervalS()100%n/a010101
getSequenceCol()100%n/a010101
isMultiTable()100%n/a010101
getDataSourceType()100%n/a010101