MTMVTask

A different version of class was executed at runtime.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,600 of 3,6000%423 of 4230%2852858308307171
getTvfInfo(String)2730%200%1111454511
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext, List)2480%260%1414595911
buildAttempts(MTMVTask.RefreshRequest, boolean)2270%490%2727464611
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)2130%220%1212525211
run()1890%220%1313515111
static {...}1780%20%22303011
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)1340%220%1212323211
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)1130%80%55252511
syncPartitionsIfNeeded(ConnectContext, List)1050%140%88262611
executeWithRetry(Callable, String)1030%160%99262611
executeSingleIvmAttempt(MTMVRefreshContext, Set)1020%60%44282811
adoptPartitionsCreatedByTheRetry(Set)1020%120%77171711
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)910%120%77222211
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)680%80%55191911
collectPctResetPartitionIds(MTMVRefreshContext, Set)680%80%55131311
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)660%60%44191911
getProgress()630%40%33121211
resolveRefreshRequest()590%60%44101011
reconcileIvmStreams(ConnectContext)590%60%44151511
hasUnusableIvmStream()510%100%66151511
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)470%40%339911
beforeMTMVRefresh()470%60%44111111
MTMVTask(long, long, MTMVTaskContext)430%n/a11121211
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)400%40%33111111
runTask()400%60%44121211
excludingRebuiltPartitions(List)390%80%559911
lambda$executeSingleIvmAttempt$0(Set, IvmIncrRefreshManager)370%n/a117711
closeOrReleaseResources()360%100%66111111
onSuccess()340%60%44111111
getIncrementalTableMap()340%40%338811
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)330%n/a11121211
setupComputeGroup(ConnectContext)330%40%33121211
executeCancelLogic(boolean)320%40%33101011
commitCapturedEpochs(Map)300%20%225511
before()290%20%229911
after()280%40%336611
holdCapturedEpochs(Map, Map)270%20%226611
recordRebuiltPartitions(MTMVTask.RefreshRequest)260%60%445511
shouldUseCompleteForInitialIvmRefresh(boolean)260%100%664411
MTMVTask()240%n/a119911
needRetry(Exception)230%80%557711
plannedCeiling(Map.Entry)220%20%222211
usableIvmStream(Database, OlapTable)220%40%336611
onFail()220%40%338811
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)220%60%447711
redeemHeldRecords()210%20%227711
isSkipPartitionSyncDebugPointEnabled()190%40%333311
registerExecutor(StmtExecutor)180%40%335511
ensureQueryUsableIfNeeded(ConnectContext, List)160%20%225511
recordCapturedPartitionId(String)160%20%224411
generateRefreshMode(List)160%40%335511
toString()160%n/a112211
resolveIvmBaseTable(BaseTableInfo)150%n/a114411
closeExecutionContext(ConnectContext)150%40%336611
recordRefreshScope(Collection)140%20%224411
recordRefreshCompleted(Collection)140%20%224411
raiseRequirementForRefreshScope(Collection)140%20%224411
buildRefreshContext(List)130%n/a113311
refreshPartitionsWithRetry(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)120%n/a111111
cancel(boolean)120%20%223311
captureLatestEpochs(Set)100%20%223311
getIvmCapturedEpochs()90%20%221111
hasRecordsHeldForTheDelta()80%20%221111
recordQueryId(String)70%20%223311
lambda$refreshPartitionsWithRetry$2(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)70%n/a111111
lambda$createRefreshConsumer$3(AtomicReference, IvmRewriteResult)50%n/a111111
createRefreshConsumer(AtomicReference)40%n/a111111
getTaskContext()30%n/a111111
getMtmvSchemaChangeVersion()30%n/a111111
getRefreshedIvmPlanSignature()30%n/a111111
lambda$collectPctResetPartitionIds$1(BaseTableInfo)0%n/a111111