StoreChangelogReader

Source file "org/apache/kafka/streams/processor/internals/StoreChangelogReader.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,874 of 1,8740%172 of 1720%1421423653655656
initializeChangelogs(Map, Set)1970%240%1313373711
restoreChangelog(StoreChangelogReader.ChangelogMetadata)1640%100%66343411
restore(Map)1620%160%99333311
prepareChangelogs(Set)1470%100%66333311
updateLimitOffsetsForStandbyChangelogs(Map)940%160%99151511
maybeLogRestorationProgress()860%80%55252511
hasRestoredToEnd(StoreChangelogReader.ChangelogMetadata)770%100%66131311
endOffsetForChangelogs(Map, Set)690%20%22141411
register(TopicPartition, ProcessorStateManager)620%80%559911
StoreChangelogReader(Time, StreamsConfig, LogContext, Admin, Consumer, StateRestoreListener)560%20%22141411
maybeUpdateLimitOffsetsForStandbyChangelogs(Map)530%80%55111111
bufferChangelogRecords(StoreChangelogReader.ChangelogMetadata, List)490%80%55101011
addChangelogsToRestoreConsumer(Set)440%20%227711
unregister(Collection)440%60%44111111
restoringChangelogByPartition(TopicPartition)420%40%336611
pauseChangelogsFromRestoreConsumer(Collection)390%20%226611
resumeChangelogsFromRestoreConsumer(Collection)390%20%226611
removeChangelogsFromRestoreConsumer(Collection)380%20%226611
transitToUpdateStandby()360%20%226611
committedOffsetForChangelogs(Map, Set)340%n/a119911
clear()300%20%229911
getTasksFromPartitions(Map, Set)290%20%225511
enforceRestoreActive()210%20%226611
lambda$maybeUpdateLimitOffsetsForStandbyChangelogs$11(Map.Entry)200%40%332211
getPositionString(TopicPartition, StoreChangelogReader.ChangelogMetadata)160%20%223311
lambda$standbyRestoringChangelogs$5(StoreChangelogReader.ChangelogMetadata)130%40%332211
lambda$activeRestoringChangelogs$3(StoreChangelogReader.ChangelogMetadata)130%40%332211
restoringChangelogs()120%n/a114411
activeRestoringChangelogs()120%n/a114411
standbyRestoringChangelogs()120%n/a114411
completedChangelogs()120%n/a114411
toString()120%n/a111111
lambda$restore$10(Set, TopicPartition)110%n/a111111
registeredChangelogs()100%n/a113311
maybeInitTaskTimeoutOrThrow(Set, Exception)100%n/a113311
lambda$completedChangelogs$8(StoreChangelogReader.ChangelogMetadata)80%20%221111
lambda$allChangelogsCompleted$7(StoreChangelogReader.ChangelogMetadata)80%20%221111
lambda$restoringChangelogs$1(StoreChangelogReader.ChangelogMetadata)80%20%221111
lambda$registeredChangelogs$0(StoreChangelogReader.ChangelogMetadata)80%20%221111
recordEndOffset(Long)70%20%221111
allChangelogsCompleted()70%n/a112211
changelogMetadata(TopicPartition)60%n/a111111
lambda$endOffsetForChangelogs$14(Map.Entry)60%n/a111111
lambda$maybeInitTaskTimeoutOrThrow$12(long, Exception, Task)50%n/a111111
static {...}50%n/a111111
setMainConsumer(Consumer)40%n/a112211
clearTaskTimeout(Set)40%n/a112211
isEmpty()40%n/a111111
lambda$initializeChangelogs$16(StoreChangelogReader.ChangelogMetadata)40%n/a111111
lambda$initializeChangelogs$15(StoreChangelogReader.ChangelogMetadata)40%n/a111111
lambda$completedChangelogs$9(StoreChangelogReader.ChangelogMetadata)40%n/a111111
lambda$standbyRestoringChangelogs$6(StoreChangelogReader.ChangelogMetadata)40%n/a111111
lambda$activeRestoringChangelogs$4(StoreChangelogReader.ChangelogMetadata)40%n/a111111
lambda$restoringChangelogs$2(StoreChangelogReader.ChangelogMetadata)40%n/a111111
state()30%n/a111111
lambda$endOffsetForChangelogs$13(TopicPartition)20%n/a111111