RoutineLoadJob

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,899 of 4,09353%192 of 35846%19732638293049143
getShowCreateInfo()3670%240%1313555511
updateNumOfData(long, long, long, long, long, boolean)16811540%15731%1012345101
update()1686527%61266%410385501
afterAborted(TransactionState, boolean, String)14311143%8850%810235001
afterVisible(TransactionState, boolean)874634%6440%56183101
setOptional(CreateRoutineLoadInfo)7221074%151346%1415155601
afterCommitted(TransactionState, boolean)644440%4450%45112401
checkMeta(OlapTable, RoutineLoadDesc)54812%8220%56111501
modifyCommonJobProperties(Map)433242%6650%67112001
plan(NereidsStreamLoadPlanner, TUniqueId, long)415758%6650%57112801
getShowStatistic()410%n/a118811
getTaskStatistic()400%n/a119911
executeBeforeCheck(TransactionState, TransactionStatus)382034%6225%4561501
appendProperties(StringBuilder, String, Object, boolean)350%60%447711
checkStateTransform(RoutineLoadJob.JobState)341022%2360%242501
executeTaskOnTxnStatusChanged(RoutineLoadTaskInfo, TransactionState, TransactionStatus, TransactionState.TxnStatusChangeReason)304761%7956%6972101
jobPropertiesToJsonString()2816385%81055%81013101
updateCloudProgress(RLTaskTxnCommitAttachment)280%n/a116611
setRoutineLoadDesc(RoutineLoadDesc)265367%81260%81162201
setComputeGroup()243760%3562%3572001
lambda$getTasksShowInfo$6(List, RoutineLoadTaskInfo)241335%5116%3461001
RoutineLoadJob(Long, String, long, long, LoadDataSourceType, UserIdentity)174271%2250%2351801
replayOnAborted(TransactionState)162460%5337%452801
isAbnormalPause()160%60%442211
beforeAborted(TransactionState)15834%1150%124701
beforeCommitted(TransactionState)15834%1150%124701
getEmptyFieldAsNull()130%20%224411
executeCancel(ErrorReason)130%n/a115511
RoutineLoadJob(Long, String, long, LoadDataSourceType, UserIdentity)124578%1150%1231701
getJsonPaths()120%20%224411
setCloudCluster()120%20%224411
getStateReason()111557%4342%351401
RoutineLoadJob(long, LoadDataSourceType)1010591%1375%1344101
getColumnExprDescs()100%20%223311
processTimeoutTasks()82575%1375%132901
hasSequenceCol()80%20%221111
isNumAsString()70%n/a111111
isFuzzyParse()70%n/a111111
lambda$getTaskStatistic$13(RoutineLoadTaskInfo)70%20%221111
lambda$getShowCreateInfo$9(StringBuilder, String, String)60%n/a111111
lambda$getShowCreateInfo$8(StringBuilder, String, String)60%n/a111111
replayUpdateProgress(RLTaskTxnCommitAttachment)51575%n/a012601
getCreateTimestampString()50%n/a111111
getPauseTimestampString()50%n/a111111
getEndTimestampString()50%n/a111111
lambda$getShowCreateInfo$7(Database)50%n/a111111
unprotectUpdateState(RoutineLoadJob.JobState, ErrorReason, boolean)45993%21285%21021901
replayOnCommitted(TransactionState)42184%1150%121601
setMemtableOnSinkNode(boolean)40%n/a112211
setCloudCluster(String)40%n/a112211
lambda$getShowCreateInfo$11(Pair)40%n/a111111
lambda$getShowCreateInfo$10(Pair)40%n/a111111
getPauseReason()0%n/a111111
getRoutineLoadStatistic()0%n/a111111
getJobStatistic()0%n/a111111
getEnclose()0%n/a111111
getEscape()0%n/a111111
getMemLimit()0%n/a111111
isFixedPartialUpdate()0%n/a111111
getSequenceCol()0%n/a111111
getErrorLogUrls()0%n/a111111
totalProgress()0%n/a111111
totalLag()0%n/a111111
lambda$getTaskStatistic$12(RoutineLoadTaskInfo)0%n/a111111
isStrictMode()1184%1150%121401
getTimezone()1083%1150%121401
getFormat()1083%1150%121401
getJsonRoot()1083%1150%121401
getFormatType()981%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
isExpired()3096%1583%140401
lambda$afterAborted$4(TransactionState, RoutineLoadTaskInfo)990%1150%120101
lambda$afterVisible$3(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
getShowInfo()166100%2100%0203001
gsonPostProcess()96100%1375%1302501
updateState(RoutineLoadJob.JobState, ErrorReason, boolean)51100%n/a0101401
getBeCurrentTasksNumMap()46100%4100%030901
getTasksShowInfo()28100%1375%130701
setOtherMsg(String)18100%n/a010401
getTableName()18100%2100%020401
getTimeout()15100%2100%020401
updateProgress(RLTaskTxnCommitAttachment)14100%n/a010301
containsTask(UUID)13100%n/a010401
executePause(ErrorReason)13100%n/a010501
getSizeOfRoutineLoadTaskInfoList()10100%n/a010301
executeNeedSchedule()10100%n/a010401
executeStop()10100%n/a010401
lambda$gsonPostProcess$14(String, String)9100%2100%020301
getDbFullName()7100%n/a010101
isStripOuterArray()7100%n/a010101
read(DataInput)7100%n/a010101
write(DataOutput)7100%n/a010201
getWorkloadGroup()6100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
lambda$getShowInfo$5(Database)5100%n/a010101
lambda$containsTask$0(UUID, RoutineLoadTaskInfo)5100%n/a010101
setComment(String)4100%n/a010201
executeRunning()4100%n/a010201
setOrigStmt(OriginStatement)4100%n/a010201
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
getTableId()100%n/a010101
getState()100%n/a010101
getAuthCode()100%n/a010101
getEndTimestamp()100%n/a010101
getPartitionNamesInfo()100%n/a010101
getUserIdentity()100%n/a010101
getMergeType()100%n/a010101
getDeleteCondition()100%n/a010101
getPrecedingFilter()100%n/a010101
getWhereExpr()100%n/a010101
getColumnSeparator()100%n/a010101
getLineDelimiter()100%n/a010101
getProgress()100%n/a010101
getMaxBatchIntervalS()100%n/a010101
getMaxBatchRows()100%n/a010101
getMaxBatchSizeBytes()100%n/a010101
getSendBatchParallelism()100%n/a010101
isLoadToSingleTablet()100%n/a010101
isMemtableOnSinkNode()100%n/a010101
getCloudCluster()100%n/a010101
isMultiTable()100%n/a010101
getDataSourceType()100%n/a010101