RoutineLoadJob

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,430 of 4,62769%158 of 46065%1653922911,09541158
unprotectGetShowCreateInfo()3760%240%1313585811
updateNumOfData(long, long, long, long, long, boolean)10516060%121045%812204701
afterVisible(TransactionState, boolean)864835%5550%46173101
update()8114464%41477%310195501
afterAborted(TransactionState, boolean, String)7411360%61062%610175001
afterCommitted(TransactionState, boolean)474448%4450%45112401
getShowStatistic()410%n/a118811
getTaskStatistic()400%n/a119911
appendProperties(StringBuilder, String, Object, boolean)350%60%447711
modifyCommonJobProperties(Map)3312579%51777%31263601
updateCloudProgress(RLTaskTxnCommitAttachment)280%n/a116611
modifyProperties(AlterRoutineLoadCommand)244464%4660%4642101
setComputeGroup()243760%2675%2572001
validateAlterJobPropertiesForMutation(AlterRoutineLoadCommand)235871%51168%4952001
executeTaskOnTxnStatusChanged(RoutineLoadTaskInfo, TransactionState, TransactionStatus, TransactionState.TxnStatusChangeReason)216274%21487%2952301
executeBeforeCheck(TransactionState, TransactionStatus)212352%4450%3551501
validateTargetTable(Database, OlapTable, Map, TUniqueKeyUpdateMode)176278%4233%3421401
replayOnAborted(TransactionState)162460%4450%352801
checkStateTransform(RoutineLoadJob.JobState)161038%2360%242501
beforeAborted(TransactionState)15834%1150%124701
beforeCommitted(TransactionState)15834%1150%124701
checkMeta(OlapTable, RoutineLoadDesc)143470%3770%3641501
getEmptyFieldAsNull()130%20%224411
RoutineLoadJob(Long, String, long, long, LoadDataSourceType, UserIdentity)124779%1375%1331801
getJsonPaths()120%20%224411
validateAlterJobProperties(OlapTable, Map, TUniqueKeyUpdateMode)112670%3770%3621101
getEffectiveUniqueKeyUpdateMode(TUniqueKeyUpdateMode, Map)111659%5337%352701
plan(NereidsStreamLoadPlanner, TUniqueId, long)109190%21285%2822901
getColumnExprDescs()100%20%223311
processTimeoutTasks()92573%1375%132901
getShowCreateInfo()90%n/a113311
validateTargetTable(Database, OlapTable)80%n/a112211
hasSequenceCol()80%20%221111
RoutineLoadJob(Long, String, long, LoadDataSourceType, UserIdentity)75087%1150%1211701
setCloudCluster()7541%1150%122401
isNumAsString()70%n/a111111
isFuzzyParse()70%n/a111111
lambda$getTaskStatistic$13(RoutineLoadTaskInfo)70%20%221111
lambda$unprotectGetShowCreateInfo$9(StringBuilder, String, String)60%n/a111111
lambda$unprotectGetShowCreateInfo$8(StringBuilder, String, String)60%n/a111111
setOptional(CreateRoutineLoadInfo)531098%92371%91716101
RoutineLoadJob(long, LoadDataSourceType)511995%4100%0324401
replayUpdateProgress(RLTaskTxnCommitAttachment)51575%n/a012601
lambda$unprotectGetShowCreateInfo$7(Database)50%n/a111111
gsonPostProcess()415397%51168%5924001
setRoutineLoadDesc(RoutineLoadDesc)46794%11794%11012001
lambda$gsonPostProcess$14(String, String)43188%1990%1611001
getTasksShowInfo()42485%2250%231701
getStateReason()42284%2571%250401
replayOnCommitted(TransactionState)42184%1150%121601
setMemtableOnSinkNode(boolean)40%n/a112211
lambda$unprotectGetShowCreateInfo$11(Pair)40%n/a111111
lambda$unprotectGetShowCreateInfo$10(Pair)40%n/a111111
jobPropertiesToJsonString()21198%12195%11203701
getEnclose()0%n/a111111
getEscape()0%n/a111111
getMemLimit()0%n/a111111
isFixedPartialUpdate()0%n/a111111
getSequenceCol()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
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
updateLag()0%n/a111111
unprotectUpdateProgress()0%n/a111111
getShowInfo()176100%2100%0203201
validateFlexiblePartialUpdateForAlter(OlapTable, Map)66100%21083%2701401
unprotectUpdateState(RoutineLoadJob.JobState, ErrorReason, boolean)63100%11392%11001901
updateState(RoutineLoadJob.JobState, ErrorReason, boolean)51100%n/a0101401
getBeCurrentTasksNumMap()46100%4100%030901
lambda$getTasksShowInfo$6(List, RoutineLoadTaskInfo)37100%2466%2401001
unprotectApplyAlter(AlterRoutineLoadCommand)30100%2100%020801
getTableName()18100%2100%020401
resetCurrentErrorStatistics()18100%n/a010601
isAbnormalPause()16100%1583%140201
getTimeout()15100%2100%020401
updateProgress(RLTaskTxnCommitAttachment)14100%n/a010301
containsTask(UUID)13100%n/a010401
executePause(ErrorReason)13100%n/a010501
executeCancel(ErrorReason)13100%n/a010501
getJsonRoot()12100%2100%020401
setOtherMsg(String)11100%n/a010401
getFormatType()11100%2100%020401
getSizeOfRoutineLoadTaskInfoList()10100%n/a010301
executeNeedSchedule()10100%n/a010401
executeStop()10100%n/a010401
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
getCreateTimestampString()5100%n/a010101
getPauseTimestampString()5100%n/a010101
getEndTimestampString()5100%n/a010101
lambda$gsonPostProcess$15(CreateRoutineLoadInfo, Table)5100%n/a010101
lambda$getShowInfo$5(Database)5100%n/a010101
lambda$containsTask$0(UUID, RoutineLoadTaskInfo)5100%n/a010101
setComment(String)4100%n/a010201
getFirstErrorMsg()4100%n/a010101
executeRunning()4100%n/a010201
setOrigStmt(OriginStatement)4100%n/a010201
setCloudCluster(String)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
getPauseReason()100%n/a010101
getRoutineLoadStatistic()100%n/a010101
getTableId()100%n/a010101
getState()100%n/a010101
getAuthCode()100%n/a010101
getEndTimestamp()100%n/a010101
getJobStatistic()100%n/a010101
getPartitionNamesInfo()100%n/a010101
getUserIdentity()100%n/a010101
getMergeType()100%n/a010101
getUniqueKeyUpdateMode()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
getErrorLogUrls()100%n/a010101
isMultiTable()100%n/a010101
getDataSourceType()100%n/a010101