MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total617 of 2,76777%117 of 32363%101219146651355
run()6712464%17729%1314185101
getProgress()5769%3125%23101201
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)530%60%44131311
syncPartitionsIfNeeded(ConnectContext, List)455856%41071%48112601
buildAttempts(MTMVTask.RefreshRequest, boolean)394352%9640%61092001
getTvfInfo(String)3323187%81260%71134401
executeSingleIvmAttempt(MTMVRefreshContext)326366%1375%1382601
handlePendingIvmBaselineRebuild(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)323250%5550%4681601
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)321937%4233%34101601
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)288775%31178%3872901
executeWithRetry(Callable, String)277673%7956%7952601
beforeMTMVRefresh()242348%2466%2451101
onFail()220%40%338811
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)139087%1787%1522301
resolveRefreshRequest()134677%1583%1421001
getIncrementalTableMap()132161%1375%133801
executeCancelLogic(boolean)131959%2250%2341001
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)125481%1583%1441901
reconcileIvmStreams(ConnectContext)116284%2675%2531801
setupComputeGroup(ConnectContext)102369%4100%0331201
before()101965%1150%123901
needRetry(Exception)101356%5337%352701
calculateNeedRefreshPartitions(MTMVRefreshContext)56292%21083%2711501
isSkipPartitionSyncDebugPointEnabled()51473%3125%230301
ensureQueryUsableIfNeeded(ConnectContext, List)41275%1150%121501
getTaskContext()30%n/a111111
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext)21699%42485%41505001
collectPctResetPartitionIds(MTMVRefreshContext, Set)6798%1787%1511301
validateIvmBaselineBeforePartitionSync(MTMVTask.RefreshRequest)6398%61266%61011401
static {...}170100%2100%0202901
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)47100%4100%030901
runTask()40100%3350%3401201
closeOrReleaseResources()36100%3770%3601101
onSuccess()34100%2466%2401101
lambda$executeSingleIvmAttempt$0(IvmIncrRefreshManager)34100%n/a010601
MTMVTask(long, long, MTMVTaskContext)25100%n/a010601
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)23100%2100%020601
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)22100%1583%140701
after()20100%1150%120401
shouldUseCompleteForInitialIvmRefresh(boolean)19100%2675%250201
registerExecutor(StmtExecutor)18100%4100%030501
generateRefreshMode(List)16100%4100%030501
toString()16100%n/a010201
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)15100%n/a010601
refreshPartitionsWithRetry(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)12100%n/a010101
cancel(boolean)12100%1150%120301
buildRefreshContext(List)11100%n/a010301
recordQueryId(String)7100%2100%020301
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
getMtmvSchemaChangeVersion()3100%n/a010101
getRefreshedIvmPlanSignature()3100%n/a010101
lambda$collectPctResetPartitionIds$1(BaseTableInfo)100%n/a010101