MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total606 of 3,93984%111 of 45975%96313142913380
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)950%120%77232311
getProgress()5769%3125%23101201
run()5016977%13940%913145901
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)3720984%42083%413106101
syncPartitionsIfNeeded(ConnectContext, List)376864%41071%4892601
getTvfInfo(String)3325488%81463%71234701
executeWithRetry(Callable, String)277673%61062%6952601
beforeMTMVRefresh()242348%2466%2451101
executeSingleIvmAttempt(MTMVRefreshContext, Set)228379%6100%0452901
onFail()220%40%338811
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext, List)1823892%22692%21536101
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)1810184%2880%2632701
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)185073%2675%2561901
buildAttempts(MTMVTask.RefreshRequest, boolean)1521593%64387%52724701
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)1412089%61672%51263201
resolveRefreshRequest()134677%1583%1421001
getIncrementalTableMap()132161%1375%133801
executeCancelLogic(boolean)131959%2250%2341001
reconcileIvmStreams(ConnectContext)114881%1583%1431501
resolveIvmBaseTable(BaseTableInfo)11426%n/a013401
setupComputeGroup(ConnectContext)102369%4100%0331201
before()101965%1150%123901
recordIvmRefreshMetrics()98190%11392%1912101
needRetry(Exception)61773%3562%251701
isSkipPartitionSyncDebugPointEnabled()51473%3125%230301
ensureQueryUsableIfNeeded(ConnectContext, List)51270%1150%121501
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)33792%1375%1311101
getTaskContext()30%n/a111111
hasUnusableIvmStream()4996%2880%2621501
after()4595%2675%2501101
adoptPartitionsCreatedByTheRetry(Set)10199%21083%2711701
collectPctResetPartitionIds(MTMVRefreshContext, Set)6798%1787%1511301
shouldUseCompleteForInitialIvmRefresh(boolean)2596%2880%260401
static {...}210100%2100%0203801
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)57100%4100%0301601
MTMVTask(long, long, MTMVTaskContext)50100%n/a0101401
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)47100%4100%030901
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)40100%n/a0101401
runTask()40100%3350%3401201
excludingRebuiltPartitions(List)39100%8100%050901
lambda$executeSingleIvmAttempt$0(Set, IvmIncrRefreshManager)37100%n/a010701
closeOrReleaseResources()36100%4660%4601101
onSuccess()34100%2466%2401101
MTMVTask()31100%n/a0101101
commitCapturedEpochs(Map)30100%2100%020501
holdCapturedEpochs(Map, Map)27100%2100%020601
recordRebuiltPartitions(MTMVTask.RefreshRequest)26100%1583%140501
onRejected()25100%1375%130801
checkNoRowTtlBaseTable()22100%2100%020701
plannedCeiling(Map.Entry)22100%2100%020201
usableIvmStream(Database, OlapTable)22100%4100%030601
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)22100%1583%140701
redeemHeldRecords()21100%2100%020701
registerExecutor(StmtExecutor)18100%4100%030501
recordCapturedPartitionId(String)16100%2100%020401
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
givingUpTheIncrementalAttemptIsAFallback()13100%4100%030101
buildRefreshContext(List)13100%n/a010301
recordCommitted(IvmRefreshMethod)12100%2100%020401
refreshPartitionsWithRetry(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)12100%n/a010101
cancel(boolean)12100%1150%120301
captureLatestEpochs(Set)10100%2100%020301
getIvmCapturedEpochs()9100%2100%020101
hasRecordsHeldForTheDelta()8100%2100%020101
recordQueryId(String)7100%2100%020301
lambda$refreshPartitionsWithRetry$2(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)7100%n/a010101
lambda$createRefreshConsumer$3(AtomicReference, IvmRewriteResult)5100%n/a010101
createRefreshConsumer(AtomicReference)4100%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