| InternalTopologyBuilder |  | 0% | | 0% | 242 | 242 | 657 | 657 | 85 | 85 | 1 | 1 |
| TaskManager | | 0% | | 0% | 202 | 202 | 669 | 669 | 75 | 75 | 1 | 1 |
| StreamsPartitionAssignor | | 0% | | 0% | 147 | 147 | 552 | 552 | 50 | 50 | 1 | 1 |
| StreamTask | | 0% | | 0% | 150 | 150 | 469 | 469 | 64 | 64 | 1 | 1 |
| StreamThread | | 0% | | 0% | 126 | 126 | 454 | 454 | 54 | 54 | 1 | 1 |
| InternalTopicManager | | 0% | | 0% | 103 | 103 | 375 | 375 | 28 | 28 | 1 | 1 |
| StoreChangelogReader | | 0% | | 0% | 142 | 142 | 365 | 365 | 56 | 56 | 1 | 1 |
| StateDirectory | | 0% | | 0% | 111 | 111 | 271 | 271 | 34 | 34 | 1 | 1 |
| ProcessorStateManager | | 0% | | 0% | 98 | 98 | 253 | 253 | 35 | 35 | 1 | 1 |
| GlobalStateManagerImpl | | 0% | | 0% | 51 | 51 | 184 | 184 | 23 | 23 | 1 | 1 |
| Tasks | | 0% | | 0% | 52 | 52 | 136 | 136 | 31 | 31 | 1 | 1 |
| PartitionGroup | | 0% | | 0% | 48 | 48 | 138 | 138 | 15 | 15 | 1 | 1 |
| ProcessorTopology | | 0% | | 0% | 45 | 45 | 109 | 109 | 23 | 23 | 1 | 1 |
| StreamsMetadataState | | 0% | | 0% | 47 | 47 | 118 | 118 | 18 | 18 | 1 | 1 |
| RecordCollectorImpl | | 0% | | 0% | 39 | 39 | 97 | 97 | 13 | 13 | 1 | 1 |
| StandbyTask | | 0% | | 0% | 38 | 38 | 94 | 94 | 22 | 22 | 1 | 1 |
| ProcessorContextImpl | | 0% | | 0% | 42 | 42 | 117 | 117 | 25 | 25 | 1 | 1 |
| GlobalStreamThread | | 0% | | 0% | 27 | 27 | 118 | 118 | 15 | 15 | 1 | 1 |
| ActiveTaskCreator | | 0% | | 0% | 23 | 23 | 91 | 91 | 13 | 13 | 1 | 1 |
| StreamsProducer | | 0% | | 0% | 31 | 31 | 112 | 112 | 15 | 15 | 1 | 1 |
| ProcessorRecordContext | | 0% | | 0% | 29 | 29 | 85 | 85 | 12 | 12 | 1 | 1 |
| RepartitionTopics | | 0% | | 0% | 30 | 30 | 82 | 82 | 9 | 9 | 1 | 1 |
| ProcessorNode | | 0% | | 0% | 25 | 25 | 72 | 72 | 16 | 16 | 1 | 1 |
| ChangelogTopics | | 0% | | 0% | 20 | 20 | 61 | 61 | 8 | 8 | 1 | 1 |
| AbstractTask | | 0% | | 0% | 21 | 21 | 60 | 60 | 13 | 13 | 1 | 1 |
| RecordQueue | | 0% | | 0% | 23 | 23 | 59 | 59 | 13 | 13 | 1 | 1 |
| StateManagerUtil | | 0% | | 0% | 20 | 20 | 52 | 52 | 6 | 6 | 1 | 1 |
| GlobalStateUpdateTask | | 0% | | 0% | 10 | 10 | 61 | 61 | 6 | 6 | 1 | 1 |
| StandbyTaskCreator | | 0% | | 0% | 9 | 9 | 43 | 43 | 7 | 7 | 1 | 1 |
| StreamsRebalanceListener | | 0% | | 0% | 12 | 12 | 46 | 46 | 4 | 4 | 1 | 1 |
| StreamThread.State | | 0% | | 0% | 8 | 8 | 15 | 15 | 4 | 4 | 1 | 1 |
| ThreadMetadataImpl | | 0% | | 0% | 23 | 23 | 33 | 33 | 12 | 12 | 1 | 1 |
| ClientUtils | | 0% | | 0% | 21 | 21 | 44 | 44 | 16 | 16 | 1 | 1 |
| InternalTopologyBuilder.TopologyDescription | | 0% | | 0% | 18 | 18 | 50 | 50 | 8 | 8 | 1 | 1 |
| AbstractProcessorContext | | 0% | | 0% | 35 | 35 | 61 | 61 | 27 | 27 | 1 | 1 |
| WindowedChangelogTopicConfig | | 0% | | 0% | 16 | 16 | 30 | 30 | 7 | 7 | 1 | 1 |
| InternalTopologyBuilder.SourceNodeFactory | | 0% | | 0% | 13 | 13 | 25 | 25 | 5 | 5 | 1 | 1 |
| InternalTopologyBuilder.Sink | | 0% | | 0% | 17 | 17 | 26 | 26 | 8 | 8 | 1 | 1 |
| PartitionGrouper | | 0% | | 0% | 11 | 11 | 28 | 28 | 4 | 4 | 1 | 1 |
| InternalTopologyBuilder.Source | | 0% | | 0% | 20 | 20 | 22 | 22 | 7 | 7 | 1 | 1 |
| RepartitionTopicConfig | | 0% | | 0% | 13 | 13 | 24 | 24 | 7 | 7 | 1 | 1 |
| InternalTopicConfig | | 0% | | 0% | 11 | 11 | 31 | 31 | 9 | 9 | 1 | 1 |
| Task.State | | 0% | | n/a | 3 | 3 | 11 | 11 | 3 | 3 | 1 | 1 |
| InternalTopologyBuilder.TopicsInfo | | 0% | | 0% | 11 | 11 | 20 | 20 | 6 | 6 | 1 | 1 |
| SinkNode | | 0% | | n/a | 6 | 6 | 30 | 30 | 6 | 6 | 1 | 1 |
| InternalTopologyBuilder.SubtopologyDescription | | 0% | | 0% | 14 | 14 | 24 | 24 | 8 | 8 | 1 | 1 |
| RecordDeserializer | | 0% | | 0% | 4 | 4 | 32 | 32 | 3 | 3 | 1 | 1 |
| GlobalProcessorContextImpl | | 0% | | 0% | 17 | 17 | 29 | 29 | 15 | 15 | 1 | 1 |
| InternalTopologyBuilder.GlobalStore | | 0% | | 0% | 12 | 12 | 21 | 21 | 7 | 7 | 1 | 1 |
| UnwindowedChangelogTopicConfig | | 0% | | 0% | 12 | 12 | 20 | 20 | 6 | 6 | 1 | 1 |
| GlobalStreamThread.StateConsumer | | 0% | | 0% | 7 | 7 | 30 | 30 | 4 | 4 | 1 | 1 |
| StoreToProcessorContextAdapter | | 0% | | 0% | 24 | 24 | 28 | 28 | 23 | 23 | 1 | 1 |
| TaskMetadataImpl | | 0% | | 0% | 14 | 14 | 21 | 21 | 9 | 9 | 1 | 1 |
| GlobalStreamThread.State | | 0% | | 0% | 7 | 7 | 10 | 10 | 5 | 5 | 1 | 1 |
| PunctuationSchedule | | 0% | | 0% | 11 | 11 | 24 | 24 | 10 | 10 | 1 | 1 |
| QuickUnion | | 0% | | 0% | 10 | 10 | 24 | 24 | 6 | 6 | 1 | 1 |
| StoreChangelogReader.ChangelogMetadata | | 0% | | 0% | 10 | 10 | 22 | 22 | 9 | 9 | 1 | 1 |
| ForwardingDisabledProcessorContext | | 0% | | n/a | 22 | 22 | 26 | 26 | 22 | 22 | 1 | 1 |
| PunctuationQueue | | 0% | | 0% | 8 | 8 | 24 | 24 | 4 | 4 | 1 | 1 |
| InternalTopologyBuilder.SinkNodeFactory | | 0% | | 0% | 5 | 5 | 14 | 14 | 3 | 3 | 1 | 1 |
| InternalTopologyBuilder.Processor | | 0% | | 0% | 11 | 11 | 15 | 15 | 5 | 5 | 1 | 1 |
| SourceNode | | 0% | | n/a | 8 | 8 | 24 | 24 | 8 | 8 | 1 | 1 |
| ProcessorStateManager.StateStoreMetadata | | 0% | | 0% | 8 | 8 | 23 | 23 | 7 | 7 | 1 | 1 |
| InternalTopologyBuilder.StateStoreFactory | | 0% | | 0% | 14 | 14 | 17 | 17 | 8 | 8 | 1 | 1 |
| AbstractReadWriteDecorator.WindowStoreReadWriteDecorator | | 0% | | n/a | 11 | 11 | 13 | 13 | 11 | 11 | 1 | 1 |
| AbstractReadOnlyDecorator | | 0% | | 0% | 11 | 11 | 17 | 17 | 6 | 6 | 1 | 1 |
| AbstractReadOnlyDecorator.WindowStoreReadOnlyDecorator | | 0% | | n/a | 11 | 11 | 12 | 12 | 11 | 11 | 1 | 1 |
| ProcessorAdapter | | 0% | | 0% | 8 | 8 | 24 | 24 | 6 | 6 | 1 | 1 |
| AbstractReadWriteDecorator.KeyValueStoreReadWriteDecorator | | 0% | | n/a | 12 | 12 | 15 | 15 | 12 | 12 | 1 | 1 |
| SerdeGetter | | 0% | | 0% | 9 | 9 | 19 | 19 | 5 | 5 | 1 | 1 |
| StateRestoreCallbackAdapter | | 0% | | 0% | 7 | 7 | 16 | 16 | 3 | 3 | 1 | 1 |
| AbstractReadOnlyDecorator.KeyValueStoreReadOnlyDecorator | | 0% | | n/a | 12 | 12 | 13 | 13 | 12 | 12 | 1 | 1 |
| AbstractReadWriteDecorator | | 0% | | 0% | 10 | 10 | 16 | 16 | 5 | 5 | 1 | 1 |
| StoreChangelogReader.ChangelogState | | 0% | | n/a | 2 | 2 | 8 | 8 | 2 | 2 | 1 | 1 |
| InternalTopologyBuilder.ProcessorNodeFactory | | 0% | | n/a | 6 | 6 | 11 | 11 | 6 | 6 | 1 | 1 |
| StateDirectory.TaskDirectory | | 0% | | 0% | 10 | 10 | 14 | 14 | 5 | 5 | 1 | 1 |
| Stamped | | 0% | | 0% | 9 | 9 | 15 | 15 | 4 | 4 | 1 | 1 |
| ProcessorContextUtils | | 0% | | 0% | 11 | 11 | 15 | 15 | 7 | 7 | 1 | 1 |
| StreamsPartitionAssignor.ClientMetadata | | 0% | | n/a | 4 | 4 | 12 | 12 | 4 | 4 | 1 | 1 |
| AbstractReadWriteDecorator.SessionStoreReadWriteDecorator | | 0% | | n/a | 8 | 8 | 11 | 11 | 8 | 8 | 1 | 1 |
| TopologyMetadata.Subtopology | | 0% | | 0% | 8 | 8 | 12 | 12 | 3 | 3 | 1 | 1 |
| StreamTask.RecordQueueCreator | | 0% | | 0% | 4 | 4 | 12 | 12 | 2 | 2 | 1 | 1 |
| AbstractReadOnlyDecorator.SessionStoreReadOnlyDecorator | | 0% | | n/a | 8 | 8 | 9 | 9 | 8 | 8 | 1 | 1 |
| StaticTopicNameExtractor | | 0% | | 0% | 8 | 8 | 12 | 12 | 5 | 5 | 1 | 1 |
| DefaultKafkaClientSupplier | | 0% | | n/a | 6 | 6 | 6 | 6 | 6 | 6 | 1 | 1 |
| StampedRecord | | 0% | | n/a | 8 | 8 | 9 | 9 | 8 | 8 | 1 | 1 |
| InternalTopologyBuilder.AbstractNode | | 0% | | n/a | 6 | 6 | 14 | 14 | 6 | 6 | 1 | 1 |
| StreamThread.ProcessingMode | | 0% | | n/a | 2 | 2 | 7 | 7 | 2 | 2 | 1 | 1 |
| Task.TaskType | | 0% | | n/a | 2 | 2 | 7 | 7 | 2 | 2 | 1 | 1 |
| StreamsMetadataState.SourceTopicsInfo | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 | 1 | 1 |
| InternalTopicManager.ValidationResult | | 0% | | n/a | 6 | 6 | 10 | 10 | 6 | 6 | 1 | 1 |
| StreamsPartitionAssignor.AssignedPartition | | 0% | | 0% | 6 | 6 | 10 | 10 | 4 | 4 | 1 | 1 |
| StoreChangelogReader.ChangelogReaderState | | 0% | | n/a | 2 | 2 | 6 | 6 | 2 | 2 | 1 | 1 |
| DefaultStreamPartitioner | | 0% | | n/a | 2 | 2 | 7 | 7 | 2 | 2 | 1 | 1 |
| Task | | 0% | | 0% | 11 | 11 | 9 | 9 | 9 | 9 | 1 | 1 |
| InternalTopologyBuilder.NodeComparator | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 | 1 | 1 |
| ToInternal | | 0% | | 0% | 7 | 7 | 9 | 9 | 6 | 6 | 1 | 1 |
| InternalTopicProperties | | 0% | | n/a | 4 | 4 | 6 | 6 | 4 | 4 | 1 | 1 |
| PartitionGroup.RecordInfo | | 0% | | n/a | 4 | 4 | 4 | 4 | 4 | 4 | 1 | 1 |
| InternalProcessorContext | | 0% | | n/a | 2 | 2 | 3 | 3 | 2 | 2 | 1 | 1 |
| StateDirectory.StateDirectoryProcessFile | | 0% | | n/a | 2 | 2 | 6 | 6 | 2 | 2 | 1 | 1 |
| InternalTopologyBuilder.GlobalStoreComparator | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 | 1 | 1 |
| InternalTopologyBuilder.SubtopologyComparator | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 | 1 | 1 |
| StreamThread.InternalConsumerConfig | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 1 | 1 |
| InternalTopologyBuilder.NodeFactory | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 | 1 | 1 |
| PunctuationSchedule.RepointableCancellable | | 0% | | n/a | 2 | 2 | 4 | 4 | 2 | 2 | 1 | 1 |
| AbstractReadOnlyDecorator.TimestampedKeyValueStoreReadOnlyDecorator | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 1 | 1 |
| AbstractReadOnlyDecorator.TimestampedWindowStoreReadOnlyDecorator | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 1 | 1 |
| ClientUtils.QuietConsumerConfig | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 1 | 1 |
| ClientUtils.QuietStreamsConfig | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 1 | 1 |
| RecordBatchingStateRestoreCallback | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |
| AbstractReadWriteDecorator.TimestampedWindowStoreReadWriteDecorator | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 1 | 1 |
| AbstractReadWriteDecorator.TimestampedKeyValueStoreReadWriteDecorator | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 1 | 1 |
| TopologyMetadata | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |