MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total711 of 3,60080%116 of 42372%99285162830371
adoptPartitionsCreatedByTheRetry(Set)1020%120%77171711
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)7813563%71568%612205201
buildAttempts(MTMVTask.RefreshRequest, boolean)6516271%103979%827124601
executeWithRetry(Callable, String)634038%9743%69152601
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext, List)5619277%81869%614135901
run()3315682%71568%61375101
excludingRebuiltPartitions(List)33615%7112%457901
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)330%n/a11121211
holdCapturedEpochs(Map, Map)270%20%226611
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)244263%2466%2471901
executeSingleIvmAttempt(MTMVRefreshContext, Set)228078%1583%1452801
redeemHeldRecords()16523%1150%125701
runTask()152562%3350%3431201
before()151448%1150%124901
executeCancelLogic(boolean)131959%1375%1341001
resolveIvmBaseTable(BaseTableInfo)11426%n/a013401
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)105885%1787%1541901
reconcileIvmStreams(ConnectContext)104983%6100%0421501
setupComputeGroup(ConnectContext)102369%4100%0331201
getTvfInfo(String)926496%41680%41124501
syncPartitionsIfNeeded(ConnectContext, List)99691%11392%1832601
resolveRefreshRequest()85186%1583%1411001
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)612895%61672%61243201
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)68593%21083%2712201
hasUnusableIvmStream()54690%3770%3631501
onSuccess()52985%2466%2411101
isSkipPartitionSyncDebugPointEnabled()51473%3125%230301
cancel(boolean)5758%1150%121301
needRetry(Exception)41982%2675%251701
after()2692%2250%230601
recordRebuiltPartitions(MTMVTask.RefreshRequest)2492%1583%140501
onFail()2090%2250%231801
captureLatestEpochs(Set)880%1150%121301
getIvmCapturedEpochs()777%1150%120101
hasRecordsHeldForTheDelta()675%1150%120101
collectPctResetPartitionIds(MTMVRefreshContext, Set)6798%1787%1511301
static {...}178100%2100%0203001
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)113100%8100%0502501
getProgress()63100%4100%0301201
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)47100%2250%230901
beforeMTMVRefresh()47100%6100%0401101
MTMVTask(long, long, MTMVTaskContext)43100%n/a0101201
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)40100%4100%0301101
lambda$executeSingleIvmAttempt$0(Set, IvmIncrRefreshManager)37100%n/a010701
closeOrReleaseResources()36100%3770%3601101
getIncrementalTableMap()34100%4100%030801
commitCapturedEpochs(Map)30100%2100%020501
shouldUseCompleteForInitialIvmRefresh(boolean)26100%1990%160401
MTMVTask()24100%n/a010901
plannedCeiling(Map.Entry)22100%2100%020201
usableIvmStream(Database, OlapTable)22100%4100%030601
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)22100%1583%140701
registerExecutor(StmtExecutor)18100%4100%030501
ensureQueryUsableIfNeeded(ConnectContext, List)16100%2100%020501
recordCapturedPartitionId(String)16100%1150%120401
generateRefreshMode(List)16100%4100%030501
toString()16100%n/a010201
closeExecutionContext(ConnectContext)15100%1375%130601
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
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
lambda$collectPctResetPartitionIds$1(BaseTableInfo)100%n/a010101