RoutineLoadJob

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,007 of 4,47732%327 of 41821%2983606461,00899147
getShowCreateInfo()3760%240%1313585811
updateNumOfData(long, long, long, long, long, boolean)2830%220%1212515111
afterAborted(TransactionState, boolean, String)2540%160%1010505011
update()1399440%16211%910345501
afterVisible(TransactionState, boolean)1340%100%66313111
validateFlexiblePartialUpdateForAlter()1240%200%1111232311
modifyCommonJobProperties(Map)1174025%16833%1213253601
afterCommitted(TransactionState, boolean)1080%80%55242411
plan(NereidsStreamLoadPlanner, TUniqueId, long)1070%140%88292911
setOptional(CreateRoutineLoadInfo)8722872%181443%1617176101
executeTaskOnTxnStatusChanged(RoutineLoadTaskInfo, TransactionState, TransactionStatus, TransactionState.TxnStatusChangeReason)780%160%99212111
setComputeGroup()610%80%55202011
executeBeforeCheck(TransactionState, TransactionStatus)580%80%55151511
checkMeta(OlapTable, RoutineLoadDesc)54812%8220%56111501
jobPropertiesToJsonString()5016476%121045%111263701
getBeCurrentTasksNumMap()460%40%339911
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
checkStateTransform(RoutineLoadJob.JobState)341022%2360%242501
updateCloudProgress(RLTaskTxnCommitAttachment)280%n/a116611
getTasksShowInfo()280%40%337711
replayOnCommitted(TransactionState)250%20%226611
setRoutineLoadDesc(RoutineLoadDesc)244766%71161%71062001
beforeAborted(TransactionState)230%20%227711
beforeCommitted(TransactionState)230%20%227711
replayUpdateProgress(RLTaskTxnCommitAttachment)200%n/a116611
getStateReason()18830%6114%452401
setOtherMsg(String)180%n/a114411
RoutineLoadJob(Long, String, long, long, LoadDataSourceType, UserIdentity)174271%2250%2351801
processTimeoutTasks()171750%3125%234901
isAbnormalPause()160%60%442211
lambda$gsonPostProcess$14(String, String)152057%5550%4641001
getTimeout()150%20%224411
updateProgress(RLTaskTxnCommitAttachment)140%n/a113311
getEmptyFieldAsNull()130%20%224411
isStrictMode()130%20%224411
containsTask(UUID)130%n/a114411
RoutineLoadJob(Long, String, long, LoadDataSourceType, UserIdentity)124578%1150%1231701
getTimezone()120%20%224411
getJsonPaths()120%20%224411
getJsonRoot()120%20%224411
setCloudCluster()120%20%224411
getFormatType()110%20%224411
RoutineLoadJob(long, LoadDataSourceType)1011191%1375%1344301
getColumnExprDescs()100%20%223311
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
hasSequenceCol()80%20%221111
isStripOuterArray()70%n/a111111
isNumAsString()70%n/a111111
isFuzzyParse()70%n/a111111
lambda$getTaskStatistic$13(RoutineLoadTaskInfo)70%20%221111
gsonPostProcess()615096%61062%6923801
getWorkloadGroup()60%n/a111111
lambda$getShowCreateInfo$9(StringBuilder, String, String)60%n/a111111
lambda$getShowCreateInfo$8(StringBuilder, String, String)60%n/a111111
getShowInfo()516697%1150%1213101
getCreateTimestampString()50%n/a111111
getPauseTimestampString()50%n/a111111
getEndTimestampString()50%n/a111111
lambda$getShowCreateInfo$7(Database)50%n/a111111
lambda$containsTask$0(UUID, RoutineLoadTaskInfo)50%n/a111111
setMemtableOnSinkNode(boolean)40%n/a112211
executeRunning()40%n/a112211
setCloudCluster(String)40%n/a112211
lambda$getShowCreateInfo$11(Pair)40%n/a111111
lambda$getShowCreateInfo$10(Pair)40%n/a111111
unprotectUpdateState(RoutineLoadJob.JobState, ErrorReason, boolean)6095%31178%31021901
isExpired()2890%2466%241401
getPauseReason()0%n/a111111
getRoutineLoadStatistic()0%n/a111111
getTableId()0%n/a111111
getAuthCode()0%n/a111111
getJobStatistic()0%n/a111111
getPartitionNamesInfo()0%n/a111111
getUserIdentity()0%n/a111111
getUniqueKeyUpdateMode()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
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
getDataSourceType()0%n/a111111
lambda$getTaskStatistic$12(RoutineLoadTaskInfo)0%n/a111111
getTableName()1688%1150%121401
getFormat()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
unprotectUpdateProgress()0%n/a111111
updateState(RoutineLoadJob.JobState, ErrorReason, boolean)51100%n/a0101401
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
read(DataInput)7100%n/a010101
write(DataOutput)7100%n/a010201
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
lambda$gsonPostProcess$15(CreateRoutineLoadInfo, Table)5100%n/a010101
lambda$getShowInfo$5(Database)5100%n/a010101
setComment(String)4100%n/a010201
setOrigStmt(OriginStatement)4100%n/a010201
getClusterInfo()4100%n/a010101
isFinal()4100%n/a010101
setMultiTable(boolean)4100%n/a010101
static {...}4100%n/a010101
getId()100%n/a010101
getName()100%n/a010101
getDbId()100%n/a010101
getState()100%n/a010101
getEndTimestamp()100%n/a010101
getMergeType()100%n/a010101
getProgress()100%n/a010101
isMultiTable()100%n/a010101