AnalysisManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,624 of 3,95558%280 of 48141%2153333528732692
replayUpdateRowsRecord(UpdateRowsEvent)2075420%29923%1620445701
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
mergeFollowerQueryColumns(Collection, Collection)700%80%55121211
buildAndAssignJob(AnalyzeTableCommand)696347%11738%810162901
showAutoPendingJobs(TableNameInfo, String)624340%1118%6781501
handleKillAnalyzeJob(KillAnalyzeJobCommand)570%60%44131311
invalidateLocalStats(long, long, long, Set, TableStatsMeta, PartitionNamesInfo)5313571%191950%142094501
updateRemotePartitionStats(long, long, long, long, Set, String)510%40%33111111
updateTaskStatus(AnalysisInfo, AnalysisState, String, long)3921384%73784%62345301
matchesFilter(TableNameInfo, TableNameInfo)381426%15316%910101401
buildAnalysisJobInfo(AnalyzeTableCommand)3626888%71365%61177101
replayNewPartitionLoadedEvent(NewPartitionLoadedEvent)330%80%558811
updateColumn(Collection, Queue)246873%61062%6931901
updateTableStatsForAlterStats(AnalysisInfo, TableIf)240%20%226611
logKilled(AnalysisInfo)220%n/a115511
sendJobId(List, boolean)1821292%71161%71064301
canSample(TableIf)180%60%444411
createAnalysisJobs(AnalyzeDatabaseCommand, boolean)170%20%225511
updatePartitionStatsCache(long, long, long, long, Set, String)170%n/a113311
updateUpdatedRows(Map, long, long, long)170%n/a116611
needAbandon(AnalysisInfo)162055%9535%783701
replayDeleteAnalysisTask(AnalyzeDeletionLog)160%n/a114411
createAnalyze(AnalyzeCommand, boolean)151854%6440%563901
dropAnalyzeJob(DropAnalyzeJobCommand)143470%1150%1211001
createAnalysisJob(AnalyzeTableCommand, boolean)132161%2250%2351101
findColStatsMeta(long, String, String)130%20%224411
readIdToTblStats(DataInput, Map)12942%1150%122501
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
writeTableStats(DataOutput)102268%1150%122701
invalidateRemoteStats(long, long, long, Set, Set, boolean)95385%3562%2531501
replayCreateAnalysisJob(AnalysisInfo)93981%2466%241801
replayCreateAnalysisTask(AnalysisInfo)93981%2466%241801
lambda$buildAndAssignJob$1(String)90%40%331111
lambda$buildAndAssignJob$0(BaseAnalysisTask)90%20%221111
lambda$findAnalysisJobs$4(String, AnalysisInfo)8538%3125%230101
addToJobIdTasksMap(long, Map)80%n/a112211
updateTableStats(AnalysisInfo)74486%4450%4521301
dropStats(TableIf, PartitionNamesInfo)72175%n/a012801
getJobProgress(long)66191%4555%4651601
submitAsyncDropStatsTask(long, long, long, PartitionNamesInfo, boolean)61976%n/a012601
updateUpdatedRows(Map)61875%2250%233901
lambda$findAnalysisJobs$6(boolean, AnalysisInfo)61266%5337%450201
recordAnalysisJob(AnalysisInfo)6857%3125%231401
lambda$findAnalysisJobs$3(long, AnalysisInfo)6753%3125%230101
checkPriv(AnalysisInfo)52482%1150%121601
updateUpdatedRows(Map, long, long)51676%n/a012701
checkPriv(BaseAnalysisTask)50%n/a112211
setNewPartitionLoaded(List)44191%41071%4811001
syncExecute(Collection)42385%n/a012801
dropExpiredStats()40%n/a112211
findAnalysisJobs(String, String, String, String, long, boolean)35494%5550%5601301
lambda$replayUpdateRowsRecord$9(Long)30%n/a111111
lambda$findAnalysisJobs$7(AnalysisInfo)30%n/a111111
findTasksByTaskIds(long)2893%2250%231501
readAnalysisInfo(DataInput, Map, boolean)2996%1583%141701
lambda$buildAnalysisJobInfo$2(OlapTable, TableIf, boolean, Pair)2796%1375%130301
lambda$findAnalysisJobs$5(boolean, long, AnalysisInfo)1090%2250%230101
lambda$findTasks$8(long, AnalysisInfo)888%1150%120101
AnalysisManager()101100%2100%0202101
createTaskForEachColumns(AnalysisInfo, Map, boolean)83100%8100%0502101
getPendingJobs(Map, JobPriority, TableNameInfo)50100%2466%2401101
write(DataOutput)30100%n/a010801
createThreadPoolForSyncAnalyze()28100%n/a010601
removeAll(List)27100%2100%020601
writeJobInfo(DataOutput, Map)22100%2100%020501
readFields(DataInput)20100%n/a010501
findTasks(long)18100%n/a010201
replayUpdateTableStatsStatus(TableStatsMeta)17100%n/a010401
replayDeleteAnalysisJob(AnalyzeDeletionLog)16100%n/a010401
removeTableStats(long)15100%n/a010401
constructJob(AnalysisInfo, Collection)15100%n/a010301
registerSysJob(AnalysisInfo, Map)12100%n/a010301
logCreateAnalysisTask(AnalysisInfo)8100%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