MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total521 of 2,81481%93 of 33572%76225126661255
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)763933%6857%58182901
calculateNeedRefreshPartitions(MTMVRefreshContext)670%120%77151511
executeWithRetry(Callable, String)634038%9743%69152601
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)462030%5116%34131901
run()4015179%101458%814105101
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext)3018886%72175%51575001
executeSingleIvmAttempt(MTMVRefreshContext)227376%4100%0352601
buildAttempts(MTMVTask.RefreshRequest, boolean)2110182%42184%41542801
validateIvmBaselineBeforePartitionSync(MTMVTask.RefreshRequest)174773%71161%51031401
runTask()152562%3350%3431201
before()151448%1150%124901
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)150%n/a116611
executeCancelLogic(boolean)131959%1375%1341001
reconcileIvmStreams(ConnectContext)106386%1787%1521801
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)104180%6100%0441601
setupComputeGroup(ConnectContext)102369%4100%0331201
syncPartitionsIfNeeded(ConnectContext, List)99491%11392%1832601
resolveRefreshRequest()85186%1583%1411001
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)64788%1583%1411301
onSuccess()52985%2466%2411101
isSkipPartitionSyncDebugPointEnabled()51473%3125%230301
cancel(boolean)5758%1150%121301
getTvfInfo(String)426098%41680%41104401
needRetry(Exception)41982%2675%251701
handlePendingIvmBaselineRebuild(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)6296%1990%1611601
onFail()2090%2250%231801
collectPctResetPartitionIds(MTMVRefreshContext, Set)6798%1787%1511301
static {...}170100%2100%0202901
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)103100%8100%0502301
getProgress()63100%4100%0301201
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)47100%2250%230901
beforeMTMVRefresh()47100%6100%0401101
closeOrReleaseResources()36100%2880%2601101
getIncrementalTableMap()34100%4100%030801
lambda$executeSingleIvmAttempt$0(IvmIncrRefreshManager)34100%n/a010601
shouldUseCompleteForInitialIvmRefresh(boolean)26100%1990%160401
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
registerExecutor(StmtExecutor)18100%4100%030501
ensureQueryUsableIfNeeded(ConnectContext, List)16100%2100%020501
generateRefreshMode(List)16100%4100%030501
toString()16100%n/a010201
refreshPartitionsWithRetry(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)12100%n/a010101
buildRefreshContext(List)11100%n/a010301
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