AnalysisManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,141 of 3,94645%328 of 48732%2493364438764192
sendJobId(List, boolean)2300%180%1010434311
replayUpdateRowsRecord(UpdateRowsEvent)11115057%191950%1420235701
showAutoPendingJobs(TableNameInfo, String)1050%120%77151511
updatePartitionRows(OlapTable, Map, TableStatsMeta, short)1030%120%77272711
updateLocalPartitionStatsCache(long, long, long, long, Set, String)960%100%66222211
dropStats(DropStatsCommand)900%180%1010191911
dropCachedStats(long, long, long)850%80%55171711
buildAnalysisInfosForNereidsDB(DatabaseIf, AnalyzeProperties)830%60%44242411
updateTaskStatus(AnalysisInfo, AnalysisState, String, long)7316969%162863%1323125301
buildAndAssignJob(AnalyzeTableCommand)706246%12633%910122901
mergeFollowerQueryColumns(Collection, Collection)700%80%55121211
getJobProgress(long)670%90%66161611
invalidateLocalStats(long, long, long, Set, TableStatsMeta, PartitionNamesInfo)5713169%201847%1520104501
findAnalysisJobs(String, String, String, String, long, boolean)570%100%66131311
handleKillAnalyzeJob(KillAnalyzeJobCommand)570%60%44131311
matchesFilter(TableNameInfo, TableNameInfo)520%180%1010141411
updateRemotePartitionStats(long, long, long, long, Set, String)510%40%33111111
getPendingJobs(Map, JobPriority, TableNameInfo)500%60%44111111
dropAnalyzeJob(DropAnalyzeJobCommand)480%20%22101011
buildAnalysisJobInfo(AnalyzeTableCommand)4427986%141246%121477401
replayNewPartitionLoadedEvent(NewPartitionLoadedEvent)330%80%558811
findTasksByTaskIds(long)300%40%335511
checkPriv(AnalysisInfo)290%20%226611
removeAll(List)270%20%226611
createAnalysisJob(AnalyzeTableCommand, boolean)181647%2250%2361101
findTasks(long)180%n/a112211
canSample(TableIf)180%60%444411
lambda$findAnalysisJobs$6(boolean, AnalysisInfo)180%80%552211
createAnalysisJobs(AnalyzeDatabaseCommand, boolean)170%20%225511
updatePartitionStatsCache(long, long, long, long, Set, String)170%n/a113311
updateUpdatedRows(Map, long, long, long)170%n/a116611
replayCreateAnalysisJob(AnalysisInfo)163266%3350%342801
replayCreateAnalysisTask(AnalysisInfo)163266%3350%342801
needAbandon(AnalysisInfo)162055%9535%783701
logKilled(AnalysisInfo)160%n/a115511
replayDeleteAnalysisJob(AnalyzeDeletionLog)160%n/a114411
replayDeleteAnalysisTask(AnalyzeDeletionLog)160%n/a114411
createAnalyze(AnalyzeCommand, boolean)151854%6440%563901
findColStatsMeta(long, String, String)130%20%224411
lambda$findAnalysisJobs$4(String, AnalysisInfo)130%40%331111
lambda$findAnalysisJobs$3(long, AnalysisInfo)130%40%331111
updateColumn(Collection, Queue)126885%51168%5931901
createTask(AnalysisInfo)111252%n/a013501
lambda$updatePartitionRows$11(long, short, Long, Long)110%n/a111111
lambda$replayUpdateRowsRecord$10(Map.Entry, Long, Long)110%n/a111111
lambda$findAnalysisJobs$5(boolean, long, AnalysisInfo)110%40%331111
invalidateRemoteStats(long, long, long, Set, Set, boolean)95385%3562%2531501
lambda$findTasks$8(long, AnalysisInfo)90%20%221111
logCreateAnalysisTask(AnalysisInfo)80%n/a113311
addToJobIdTasksMap(long, Map)80%n/a112211
updateTableStats(AnalysisInfo)74486%4450%4521301
dropStats(TableIf, PartitionNamesInfo)72175%n/a012801
submitAsyncDropStatsTask(long, long, long, PartitionNamesInfo, boolean)61976%n/a012601
updateUpdatedRows(Map)61875%2250%233901
recordAnalysisJob(AnalysisInfo)6857%3125%231401
updateUpdatedRows(Map, long, long)51676%n/a012701
checkPriv(BaseAnalysisTask)50%n/a112211
dropExpiredStats()40%n/a112211
readAnalysisInfo(DataInput, Map, boolean)32790%2466%241701
lambda$replayUpdateRowsRecord$9(Long)30%n/a111111
lambda$findAnalysisJobs$7(AnalysisInfo)30%n/a111111
lambda$buildAndAssignJob$1(String)777%2250%230101
lambda$buildAndAssignJob$0(BaseAnalysisTask)777%1150%120101
lambda$buildAnalysisJobInfo$2(OlapTable, TableIf, boolean, Pair)2796%2250%230301
AnalysisManager()101100%2100%0202101
createTaskForEachColumns(AnalysisInfo, Map, boolean)83100%2675%2502101
setNewPartitionLoaded(List)45100%31178%3801001
writeTableStats(DataOutput)32100%2100%020701
write(DataOutput)30100%n/a010801
createThreadPoolForSyncAnalyze()28100%n/a010601
syncExecute(Collection)27100%n/a010801
updateTableStatsForAlterStats(AnalysisInfo, TableIf)24100%2100%020601
writeJobInfo(DataOutput, Map)22100%2100%020501
readIdToTblStats(DataInput, Map)21100%2100%020501
readFields(DataInput)20100%n/a010501
replayUpdateTableStatsStatus(TableStatsMeta)17100%n/a010401
removeTableStats(long)15100%n/a010401
constructJob(AnalysisInfo, Collection)15100%n/a010301
registerSysJob(AnalysisInfo, Map)12100%n/a010301
logCreateAnalysisJob(AnalysisInfo)8100%n/a010301
findTableStatsStatus(long)7100%n/a010101
updateTableStatsStatus(TableStatsMeta)7100%n/a010301
getIdToTblStatsKeys()7100%n/a010101
findJobInfo(long)7100%n/a010101
removeJob(long)7100%n/a010201
updateHighPriorityColumn(Set)6100%n/a010201
updateMidPriorityColumn(Collection)6100%n/a010201
logCreateTableStats(TableStatsMeta)5100%n/a010201
logUpdateRowsRecord(UpdateRowsEvent)5100%n/a010201
logNewPartitionLoadedEvent(NewPartitionLoadedEvent)5100%n/a010201
static {...}4100%n/a010101
getStatisticsCache()3100%n/a010101