MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total493 of 3,93987%92 of 45979%82313115913280
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)5219478%61875%613156101
buildAttempts(MTMVTask.RefreshRequest, boolean)5217877%94081%727104701
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)400%n/a11141411
run()3718283%61672%51385901
adoptPartitionsCreatedByTheRetry(Set)376563%5758%4761701
excludingRebuiltPartitions(List)33615%7112%457901
onRejected()250%40%338811
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext, List)2423290%32589%21566101
checkNoRowTtlBaseTable()17522%20%124701
runTask()152562%3350%3431201
before()151448%1150%124901
recordIvmRefreshMetrics()147684%41071%4952101
executeCancelLogic(boolean)131959%1375%1341001
resolveIvmBaseTable(BaseTableInfo)11426%n/a013401
executeSingleIvmAttempt(MTMVRefreshContext, Set)109590%1583%1422901
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)105885%1787%1541901
reconcileIvmStreams(ConnectContext)104983%6100%0421501
setupComputeGroup(ConnectContext)102369%4100%0331201
getTvfInfo(String)927896%41881%41224701
executeWithRetry(Callable, String)99491%31381%3922601
resolveRefreshRequest()85186%1583%1411001
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)68993%11191%1712301
hasUnusableIvmStream()54690%3770%3631501
onSuccess()52985%2466%2411101
givingUpTheIncrementalAttemptIsAFallback()5861%3125%230101
cancel(boolean)5758%1150%121301
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)313197%41881%41223201
after()4595%2675%2501101
needRetry(Exception)2191%1787%150701
onFail()2090%2250%231801
captureLatestEpochs(Set)880%1150%121301
getIvmCapturedEpochs()777%1150%120101
hasRecordsHeldForTheDelta()675%1150%120101
collectPctResetPartitionIds(MTMVRefreshContext, Set)6798%1787%1511301
static {...}210100%2100%0203801
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)119100%10100%0602701
syncPartitionsIfNeeded(ConnectContext, List)105100%14100%0802601
getProgress()63100%4100%0301201
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)57100%4100%0301601
MTMVTask(long, long, MTMVTaskContext)50100%n/a0101401
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)47100%2250%230901
beforeMTMVRefresh()47100%6100%0401101
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)40100%4100%0301101
lambda$executeSingleIvmAttempt$0(Set, IvmIncrRefreshManager)37100%n/a010701
closeOrReleaseResources()36100%3770%3601101
getIncrementalTableMap()34100%4100%030801
MTMVTask()31100%n/a0101101
commitCapturedEpochs(Map)30100%2100%020501
holdCapturedEpochs(Map, Map)27100%2100%020601
recordRebuiltPartitions(MTMVTask.RefreshRequest)26100%6100%040501
shouldUseCompleteForInitialIvmRefresh(boolean)26100%1990%160401
plannedCeiling(Map.Entry)22100%2100%020201
usableIvmStream(Database, OlapTable)22100%4100%030601
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)22100%6100%040701
redeemHeldRecords()21100%2100%020701
isSkipPartitionSyncDebugPointEnabled()19100%4100%030301
registerExecutor(StmtExecutor)18100%4100%030501
ensureQueryUsableIfNeeded(ConnectContext, List)17100%2100%020501
recordCapturedPartitionId(String)16100%1150%120401
generateRefreshMode(List)16100%4100%030501
toString()16100%n/a010201
closeExecutionContext(ConnectContext)15100%4100%030601
recordRefreshScope(Collection)14100%2100%020401
recordRefreshCompleted(Collection)14100%2100%020401
raiseRequirementForRefreshScope(Collection)14100%2100%020401
buildRefreshContext(List)13100%n/a010301
recordCommitted(IvmRefreshMethod)12100%2100%020401
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
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
getIvmRefreshMethod()3100%n/a010101
getIvmFailureReason()3100%n/a010101
isIvmFallback()3100%n/a010101
getIvmFallbackReason()3100%n/a010101
lambda$collectPctResetPartitionIds$1(BaseTableInfo)100%n/a010101