GlobalStateManagerImpl

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total888 of 8880%56 of 560%51511841842323
restoreState(StateRestoreCallback, List, Map, String, RecordConverter)1470%120%77333311
GlobalStateManagerImpl(LogContext, Time, ProcessorTopology, Consumer, StateDirectory, StateRestoreListener, StreamsConfig)1260%40%33272711
registerStore(StateStore, StateRestoreCallback)1030%60%44181811
close()920%80%55212111
topicPartitionsForStore(StateStore)710%60%44101011
flush()700%40%33141411
initialize()580%20%22121211
maybeUpdateDeadlineOrThrow(long)490%60%448811
checkpoint()480%40%33111111
retryUntilSuccessOrThrowOnTaskTimeout(Supplier, String)340%20%229911
lambda$initialize$0(Set, TopicPartition)200%20%226611
getGlobalConsumerOffset(TopicPartition)160%n/a112211
getGlobalStore(String)100%n/a111111
changelogFor(String)60%n/a111111
lambda$getGlobalConsumerOffset$3(TopicPartition)60%n/a111111
updateChangelogOffsets(Map)50%n/a112211
lambda$topicPartitionsForStore$2(String)50%n/a111111
lambda$registerStore$1(List)50%n/a111111
setGlobalProcessorContext(InternalProcessorContext)40%n/a112211
getStore(String)40%n/a111111
changelogOffsets()40%n/a111111
baseDir()30%n/a111111
taskType()20%n/a111111