RoutineLoadJob

A different version of class was executed at runtime.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total4,093 of 4,0930%358 of 3580%326326930930143143
getShowCreateInfo()3670%240%1313555511
updateNumOfData(long, long, long, long, long, boolean)2830%220%1212515111
setOptional(CreateRoutineLoadInfo)2820%280%1515565611
afterAborted(TransactionState, boolean, String)2540%160%1010505011
update()2330%180%1010555511
jobPropertiesToJsonString()1910%180%1010313111
getShowInfo()1660%20%22303011
afterVisible(TransactionState, boolean)1330%100%66313111
RoutineLoadJob(long, LoadDataSourceType)1150%40%33414111
afterCommitted(TransactionState, boolean)1080%80%55242411
plan(NereidsStreamLoadPlanner, TUniqueId, long)980%120%77282811
gsonPostProcess()960%40%33252511
setRoutineLoadDesc(RoutineLoadDesc)790%200%1111222211
executeTaskOnTxnStatusChanged(RoutineLoadTaskInfo, TransactionState, TransactionStatus, TransactionState.TxnStatusChangeReason)770%160%99212111
modifyCommonJobProperties(Map)750%120%77202011
unprotectUpdateState(RoutineLoadJob.JobState, ErrorReason, boolean)630%140%1010191911
checkMeta(OlapTable, RoutineLoadDesc)620%100%66151511
setComputeGroup()610%80%55202011
RoutineLoadJob(Long, String, long, long, LoadDataSourceType, UserIdentity)590%40%33181811
executeBeforeCheck(TransactionState, TransactionStatus)580%80%55151511
RoutineLoadJob(Long, String, long, LoadDataSourceType, UserIdentity)570%20%22171711
updateState(RoutineLoadJob.JobState, ErrorReason, boolean)510%n/a11141411
getBeCurrentTasksNumMap()460%40%339911
checkStateTransform(RoutineLoadJob.JobState)440%50%445511
getShowStatistic()410%n/a118811
replayOnAborted(TransactionState)400%80%558811
getTaskStatistic()400%n/a119911
lambda$getTasksShowInfo$6(List, RoutineLoadTaskInfo)370%60%44101011
appendProperties(StringBuilder, String, Object, boolean)350%60%447711
processTimeoutTasks()330%40%339911
isExpired()310%60%444411
updateCloudProgress(RLTaskTxnCommitAttachment)280%n/a116611
getTasksShowInfo()280%40%337711
getStateReason()260%70%554411
replayOnCommitted(TransactionState)250%20%226611
beforeAborted(TransactionState)230%20%227711
beforeCommitted(TransactionState)230%20%227711
replayUpdateProgress(RLTaskTxnCommitAttachment)200%n/a116611
setOtherMsg(String)180%n/a114411
getTableName()180%20%224411
isAbnormalPause()160%60%442211
getTimeout()150%20%224411
updateProgress(RLTaskTxnCommitAttachment)140%n/a113311
getEmptyFieldAsNull()130%20%224411
isStrictMode()130%20%224411
containsTask(UUID)130%n/a114411
executePause(ErrorReason)130%n/a115511
executeCancel(ErrorReason)130%n/a115511
getTimezone()120%20%224411
getFormat()120%20%224411
getJsonPaths()120%20%224411
getJsonRoot()120%20%224411
setCloudCluster()120%20%224411
getFormatType()110%20%224411
getColumnExprDescs()100%20%223311
getSizeOfRoutineLoadTaskInfoList()100%n/a113311
executeNeedSchedule()100%n/a114411
executeStop()100%n/a114411
lambda$afterAborted$4(TransactionState, RoutineLoadTaskInfo)100%20%221111
lambda$afterVisible$3(TransactionState, RoutineLoadTaskInfo)100%20%221111
lambda$afterCommitted$2(TransactionState, RoutineLoadTaskInfo)100%20%221111
lambda$executeBeforeCheck$1(TransactionState, RoutineLoadTaskInfo)100%20%221111
lambda$gsonPostProcess$14(String, String)90%20%223311
hasSequenceCol()80%20%221111
getDbFullName()70%n/a111111
isStripOuterArray()70%n/a111111
isNumAsString()70%n/a111111
isFuzzyParse()70%n/a111111
read(DataInput)70%n/a111111
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
lambda$getShowCreateInfo$8(StringBuilder, String, String)60%n/a111111
readLock()50%n/a112211
readUnlock()50%n/a112211
writeLock()50%n/a112211
writeUnlock()50%n/a112211
getCreateTimestampString()50%n/a111111
getPauseTimestampString()50%n/a111111
getEndTimestampString()50%n/a111111
lambda$getShowCreateInfo$7(Database)50%n/a111111
lambda$getShowInfo$5(Database)50%n/a111111
lambda$containsTask$0(UUID, RoutineLoadTaskInfo)50%n/a111111
setMemtableOnSinkNode(boolean)40%n/a112211
setComment(String)40%n/a112211
executeRunning()40%n/a112211
setOrigStmt(OriginStatement)40%n/a112211
setCloudCluster(String)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
static {...}40%n/a111111
getId()0%n/a111111
getName()0%n/a111111
getDbId()0%n/a111111
getPauseReason()0%n/a111111
getRoutineLoadStatistic()0%n/a111111
getTableId()0%n/a111111
getState()0%n/a111111
getAuthCode()0%n/a111111
getEndTimestamp()0%n/a111111
getJobStatistic()0%n/a111111
getPartitions()0%n/a111111
getUserIdentity()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
getMemLimit()0%n/a111111
getProgress()0%n/a111111
getMaxBatchIntervalS()0%n/a111111
getMaxBatchRows()0%n/a111111
getMaxBatchSizeBytes()0%n/a111111
getSendBatchParallelism()0%n/a111111
isLoadToSingleTablet()0%n/a111111
isFixedPartialUpdate()0%n/a111111
getSequenceCol()0%n/a111111
isMemtableOnSinkNode()0%n/a111111
getCloudCluster()0%n/a111111
getErrorLogUrls()0%n/a111111
totalProgress()0%n/a111111
totalLag()0%n/a111111
isMultiTable()0%n/a111111
getDataSourceType()0%n/a111111
lambda$getTaskStatistic$12(RoutineLoadTaskInfo)0%n/a111111
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
unprotectUpdateProgress()0%n/a111111