Source file "org/apache/kafka/streams/processor/internals/ProcessorStateManager.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 1,221 of 1,221 | 0% | 126 of 126 | 0% | 98 | 98 | 253 | 253 | 35 | 35 |
| initializeStoreOffsetsFromCheckpoint(boolean) | | 0% | | 0% | 11 | 11 | 38 | 38 | 1 | 1 |
| registerStore(StateStore, StateRestoreCallback) | | 0% | | 0% | 5 | 5 | 16 | 16 | 1 | 1 |
| flushCache() | | 0% | | 0% | 8 | 8 | 22 | 22 | 1 | 1 |
| close() | | 0% | | 0% | 6 | 6 | 21 | 21 | 1 | 1 |
| restore(ProcessorStateManager.StateStoreMetadata, List) | | 0% | | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
| flush() | | 0% | | 0% | 6 | 6 | 19 | 19 | 1 | 1 |
| ProcessorStateManager(TaskId, Task.TaskType, boolean, LogContext, StateDirectory, ChangelogRegister, Map, Collection) | | 0% | n/a | 1 | 1 | 15 | 15 | 1 | 1 | |
| checkpoint() | | 0% | | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
| markChangelogAsCorrupted(Collection) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| updateChangelogOffsets(Map) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| transitionTaskType(Task.TaskType, LogContext) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| registeredChangelogPartitionFor(String) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| findStore(TopicPartition) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| changelogOffsets() | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| registerStateStores(List, InternalProcessorContext) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| getAllChangelogTopicPartitions() | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| registerGlobalStateStores(List) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| storeMetadata(TopicPartition) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| recycle() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| getStore(String) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| storeChangelogTopic(String, String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| maybeRegisterStoreWithChangelogReader(String) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| getStorePartition(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| changelogOffsetFromCheckpointedOffset(long) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| isLoggingEnabled(String) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| checkpointableOffsetFromChangelogOffset(Long) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| deleteCheckPointFileIfEOSEnabled() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| getGlobalStore(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| changelogFor(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| changelogAsSource(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$findStore$0(TopicPartition, ProcessorStateManager.StateStoreMetadata) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| changelogPartitions() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| baseDir() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| taskId() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| taskType() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |