RoutineLoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total683 of 2,22869%83 of 20659%701681454911065
getMinTaskBeId(String)1030%120%77222211
checkPrivAndGetAllJobs(String)700%120%77171711
getAvailableBeForTask(long, long)6512565%131756%1216114001
cleanOverLimitRoutineLoadJobs()60811%8220%56202301
getAvailableBackendIds(long)594543%6650%67102301
getTagsFromReplicaAllocation(long, long)510%20%22111111
getJobByName(String)360%40%338811
addRoutineLoadJob(RoutineLoadJob, String, String)315061%2250%2321201
checkPrivAndGetJob(String, String)308072%1787%1551901
isInBlacklist(long)271128%3125%235801
getSizeOfIdToRoutineLoadTask()220%20%225511
pauseRoutineLoadJob(PauseRoutineLoadCommand)187380%3350%2452101
resumeRoutineLoadJob(ResumeRoutineLoadCommand)186578%3350%2452301
getJob(String, String, boolean, PatternMatcher)1710986%31583%31052801
alterRoutineLoadJob(AlterRoutineLoadCommand)143068%1375%1321001
createRoutineLoadJob(CreateRoutineLoadInfo, ConnectContext)138186%1375%1311901
replayChangeRoutineLoadJob(RoutineLoadOperation)123775%n/a0131301
addToBlacklist(long)90%n/a112211
getTotalMaxConcurrentTaskNum()80%n/a111111
getAvailableBackendIdsForUt(long)40%n/a111111
cleanOldRoutineLoadJobs()3770%1150%121401
lambda$cleanOverLimitRoutineLoadJobs$11(RoutineLoadJob)30%n/a111111
lambda$getTotalMaxConcurrentTaskNum$3(Integer)30%n/a111111
getRoutineLoadJobByMultiLoadTaskTxnId(long)21990%1150%121401
checkTaskInJob(RoutineLoadTaskInfo)21588%1150%121401
lambda$isNameUsed$7(RoutineLoadJob)2675%1150%120101
sortRoutineLoadJob(List)5798%21285%2811501
getBeCurrentTasksNumMap()71100%6100%0401101
readFields(DataInput)71100%8100%0501601
clearRoutineLoadJobIf(Predicate)66100%4100%0301901
unprotectedRemoveJobFromDb(RoutineLoadJob)55100%4100%030601
getClusterIdleSlotNum()53100%4100%0301001
stopRoutineLoadJob(StopRoutineLoadCommand)52100%n/a0101201
unprotectedAddJob(RoutineLoadJob)34100%n/a010801
isNameUsed(Long, String)34100%4100%030901
RoutineLoadManager()28100%n/a010801
replayRemoveOldRoutineLoad(RoutineLoadOperation)24100%1150%120701
write(DataOutput)22100%2100%020501
updateRoutineLoadJob()20100%4100%030501
getJob(String, String)17100%2100%020401
replayCreateRoutineLoadJob(RoutineLoadJob)17100%n/a010501
processTimeoutTasks()16100%2100%020401
replayAlterRoutineLoadJob(AlterRoutineLoadJobOperationLog)15100%n/a010401
getRoutineLoadJobByState(Set)13100%n/a010301
updateBeIdToMaxConcurrentTasks()12100%n/a010301
getActiveRoutineLoadJobs()10100%n/a010301
addMultiLoadTaskTxnIdToRoutineLoadJobId(long, long)9100%n/a010201
lambda$getJob$8(RoutineLoadJob)8100%2100%020101
lambda$getActiveRoutineLoadJobs$0(RoutineLoadJob)8100%2100%020101
getAllRoutineLoadJobs()7100%n/a010101
removeMultiLoadTaskTxnIdToRoutineLoadJobId(long)7100%n/a010201
getJob(long)7100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
lambda$getRoutineLoadJobByState$10(Set, RoutineLoadJob)5100%n/a010101
lambda$getJob$9(PatternMatcher, RoutineLoadJob)5100%n/a010101
lambda$isNameUsed$6(String, RoutineLoadJob)5100%n/a010101
static {...}4100%n/a010101
getBlacklist()3100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$2(Long)3100%n/a010101
lambda$unprotectedAddJob$5(String)2100%n/a010101
lambda$unprotectedAddJob$4(Long)2100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$1(Long)2100%n/a010101