MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total677 of 3,60081%122 of 42371%103285158830271
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)9212156%91359%712205201
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)910%120%77222211
run()6612365%16627%1213175101
getProgress()5769%3125%23101201
syncPartitionsIfNeeded(ConnectContext, List)456057%41071%48112601
getTvfInfo(String)3324087%81260%71134501
executeWithRetry(Callable, String)277673%7956%7952601
beforeMTMVRefresh()242348%2466%2451101
executeSingleIvmAttempt(MTMVRefreshContext, Set)228078%6100%0452801
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext, List)1823092%42284%41435901
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)185073%2675%2561901
onFail()17522%40%237801
buildAttempts(MTMVTask.RefreshRequest, boolean)1521293%64387%52724601
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)1412089%61672%51263201
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)1310088%1787%1522501
resolveRefreshRequest()134677%1583%1421001
getIncrementalTableMap()132161%1375%133801
executeCancelLogic(boolean)131959%2250%2341001
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)125481%1583%1441901
reconcileIvmStreams(ConnectContext)114881%1583%1431501
resolveIvmBaseTable(BaseTableInfo)11426%n/a013401
setupComputeGroup(ConnectContext)102369%4100%0331201
before()101965%1150%123901
needRetry(Exception)101356%5337%352701
isSkipPartitionSyncDebugPointEnabled()51473%3125%230301
ensureQueryUsableIfNeeded(ConnectContext, List)41275%1150%121501
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)33792%1375%1311101
getTaskContext()30%n/a111111
hasUnusableIvmStream()4996%2880%2621501
after()2692%2250%230601
adoptPartitionsCreatedByTheRetry(Set)10199%21083%2711701
collectPctResetPartitionIds(MTMVRefreshContext, Set)6798%1787%1511301
shouldUseCompleteForInitialIvmRefresh(boolean)2596%2880%260401
static {...}178100%2100%0203001
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)47100%4100%030901
MTMVTask(long, long, MTMVTaskContext)43100%n/a0101201
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(MTMV, MTMVRelation, MTMVTaskContext)33100%n/a0101201
commitCapturedEpochs(Map)30100%2100%020501
holdCapturedEpochs(Map, Map)27100%2100%020601
recordRebuiltPartitions(MTMVTask.RefreshRequest)26100%1583%140501
MTMVTask()24100%n/a010901
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
buildRefreshContext(List)13100%n/a010301
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
lambda$collectPctResetPartitionIds$1(BaseTableInfo)100%n/a010101