MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total511 of 3,16483%89 of 38376%78254129754160
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)714438%6857%58172901
executeWithRetry(Callable, String)634038%9743%69152601
handlePendingIvmBaselineRebuild(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)449869%71365%511123801
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext)4017881%71770%513105101
run()3315982%71568%61375101
buildAttempts(MTMVTask.RefreshRequest, boolean)2712982%33090%31953401
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)244263%2466%2471901
executeSingleIvmAttempt(MTMVRefreshContext)227376%4100%0352601
validateIvmBaselineBeforePartitionSync(MTMVTask.RefreshRequest)174773%61266%41031401
runTask()152562%3350%3431201
before()151448%1150%124901
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)150%n/a116611
executeCancelLogic(boolean)131959%1375%1341001
resolveIvmBaseTable(BaseTableInfo)11426%n/a013401
reconcileIvmStreams(ConnectContext)104983%6100%0421501
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)104180%6100%0441601
setupComputeGroup(ConnectContext)102369%4100%0331201
getTvfInfo(String)925596%41680%41124401
syncPartitionsIfNeeded(ConnectContext, List)99691%11392%1832601
resolveRefreshRequest()85186%1583%1411001
registerExecutor(StmtExecutor)81055%1375%132501
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)68693%21083%2712301
hasUnusableIvmStream()64588%4660%4641501
onSuccess()52985%2466%2411101
isSkipPartitionSyncDebugPointEnabled()51473%3125%230301
cancel(boolean)5758%1150%121301
needRetry(Exception)41982%2675%251701
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)313197%41881%41223201
onFail()2090%2250%231801
collectPctResetPartitionIds(MTMVRefreshContext, Set)6798%1787%1511301
static {...}170100%2100%0202901
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)113100%8100%0502501
getProgress()63100%4100%0301201
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)47100%2250%230901
beforeMTMVRefresh()47100%6100%0401101
lambda$executeSingleIvmAttempt$0(IvmIncrRefreshManager)38100%n/a010701
closeOrReleaseResources()36100%2880%2601101
getIncrementalTableMap()34100%4100%030801
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)33100%4100%030901
shouldUseCompleteForInitialIvmRefresh(boolean)26100%1990%160401
MTMVTask(long, long, MTMVTaskContext)25100%n/a010601
usableIvmStream(Database, OlapTable)22100%4100%030601
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)22100%1583%140701
after()20100%1150%120401
ensureQueryUsableIfNeeded(ConnectContext, List)16100%2100%020501
generateRefreshMode(List)16100%4100%030501
toString()16100%n/a010201
closeExecutionContext(ConnectContext)15100%1375%130601
writeIvmBaselineBarrier(RefreshMTMVInfo.RefreshMode)14100%2100%020301
buildRefreshContext(List)13100%n/a010301
refreshPartitionsWithRetry(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)12100%n/a010101
recordQueryId(String)7100%1150%120301
lambda$refreshPartitionsWithRetry$2(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)7100%n/a010101
MTMVTask()6100%n/a010301
lambda$createRefreshConsumer$3(AtomicReference, IvmRewriteResult)5100%n/a010101
createRefreshConsumer(AtomicReference)4100%n/a010101
getTaskContext()3100%n/a010101
getMtmvSchemaChangeVersion()3100%n/a010101
getRefreshedIvmPlanSignature()3100%n/a010101
lambda$collectPctResetPartitionIds$1(BaseTableInfo)100%n/a010101