MTMVTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total432 of 3,56387%83 of 42180%7628299821169
buildAttempts(MTMVTask.RefreshRequest, boolean)6516271%103979%827124601
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)4217180%51777%512125201
run()3315682%61672%51375101
excludingRebuiltPartitions(List)33615%7112%457901
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)330%n/a11121211
adoptPartitionsCreatedByTheRetry(Set)256572%5758%4741501
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext, List)2422890%32388%21466001
runTask()152562%3350%3431201
before()151448%1150%124901
executeCancelLogic(boolean)131959%1375%1341001
resolveIvmBaseTable(BaseTableInfo)11426%n/a013401
executeSingleIvmAttempt(MTMVRefreshContext, Set)109290%1583%1422801
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)105885%1787%1541901
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)105684%1583%1431901
reconcileIvmStreams(ConnectContext)104983%6100%0421501
setupComputeGroup(ConnectContext)102369%4100%0331201
getTvfInfo(String)926496%41680%41124501
executeWithRetry(Callable, String)99491%31381%3922601
resolveRefreshRequest()85186%1583%1411001
registerExecutor(StmtExecutor)81055%1375%132501
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)68593%11191%1712201
hasUnusableIvmStream()54690%3770%3631501
onSuccess()52985%2466%2411101
cancel(boolean)5758%1150%121301
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)313197%41881%41223201
after()2692%2250%230601
recordRebuiltPartitions(MTMVTask.RefreshRequest)2492%1583%140501
needRetry(Exception)2191%1787%150701
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
syncPartitionsIfNeeded(ConnectContext, List)105100%14100%0802601
getProgress()63100%4100%0301201
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)47100%2250%230901
beforeMTMVRefresh()47100%6100%0401101
commitCapturedEpochs(Map)44100%1375%130701
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
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
redeemHeldRecords()21100%2100%020701
isSkipPartitionSyncDebugPointEnabled()19100%4100%030301
ensureQueryUsableIfNeeded(ConnectContext, List)16100%2100%020501
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
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