MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,177 of 3,60767%175 of 42558%1362862908321571
run()1890%220%1313515111
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)9212156%91359%712205201
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)910%120%77222211
syncPartitionsIfNeeded(ConnectContext, List)693634%10428%78152601
reconcileIvmStreams(ConnectContext)590%60%44151511
getProgress()5769%3125%23101201
beforeMTMVRefresh()470%60%44111111
MTMVTask(long, long, MTMVTaskContext)430%n/a11121211
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)400%40%33111111
runTask()400%60%44121211
closeOrReleaseResources()360%100%66111111
getTvfInfo(String)3523887%91155%81134501
onSuccess()340%60%44111111
executeCancelLogic(boolean)320%40%33101011
executeWithRetry(Callable, String)297471%8850%8962601
before()290%20%229911
executeSingleIvmAttempt(MTMVRefreshContext, Set)228078%6100%0452801
onFail()220%40%338811
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)219882%4660%4642701
buildAttempts(MTMVTask.RefreshRequest, boolean)2020791%74285%62744601
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext, List)1823092%42284%41435901
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)185073%2675%2561901
ensureQueryUsableIfNeeded(ConnectContext, List)170%20%225511
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)1412089%61672%51263201
resolveRefreshRequest()134677%1583%1421001
getIncrementalTableMap()132161%2250%233801
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)125481%1583%1441901
cancel(boolean)120%20%223311
resolveIvmBaseTable(BaseTableInfo)11426%n/a013401
setupComputeGroup(ConnectContext)102369%4100%0331201
needRetry(Exception)101356%5337%352701
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)54289%1375%131901
isSkipPartitionSyncDebugPointEnabled()51473%3125%230301
getTaskContext()30%n/a111111
hasUnusableIvmStream()4996%2880%2621501
after()2692%2250%230601
generateRefreshMode(List)1487%1375%131501
adoptPartitionsCreatedByTheRetry(Set)10199%21083%2711701
collectPctResetPartitionIds(MTMVRefreshContext, Set)6798%1787%1511301
shouldUseCompleteForInitialIvmRefresh(boolean)2596%2880%260401
static {...}178100%2100%0203001
excludingRebuiltPartitions(List)39100%8100%050901
lambda$executeSingleIvmAttempt$0(Set, IvmIncrRefreshManager)37100%n/a010701
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%1375%130601
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)22100%2466%240701
redeemHeldRecords()21100%2100%020701
registerExecutor(StmtExecutor)18100%4100%030501
recordCapturedPartitionId(String)16100%2100%020401
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
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