org.apache.kafka.streams.processor.internals

Element	Missed Instructions	Cov.	Missed Branches	Cov.	Missed	Cxty	Missed	Lines	Missed	Methods	Missed	Classes
Total	34,856 of 34,856	0%	2,734 of 2,734	0%	2,668	2,668	7,313	7,313	1,285	1,285	114	114
InternalTopologyBuilder.java		0%		0%	397	397	933	933	166	166	17	17
TaskManager.java		0%		0%	202	202	669	669	75	75	1	1
StreamsPartitionAssignor.java		0%		0%	157	157	574	574	58	58	3	3
StreamTask.java		0%		0%	154	154	481	481	66	66	2	2
StreamThread.java		0%		0%	137	137	478	478	61	61	4	4
StoreChangelogReader.java		0%		0%	156	156	401	401	69	69	4	4
InternalTopicManager.java		0%		0%	109	109	385	385	34	34	2	2
StateDirectory.java		0%		0%	123	123	291	291	41	41	3	3
ProcessorStateManager.java		0%		0%	106	106	276	276	42	42	2	2
GlobalStateManagerImpl.java		0%		0%	51	51	184	184	23	23	1	1
Tasks.java		0%		0%	52	52	136	136	31	31	1	1
GlobalStreamThread.java		0%		0%	41	41	158	158	24	24	3	3
PartitionGroup.java		0%		0%	52	52	142	142	19	19	2	2
StreamsMetadataState.java		0%		0%	50	50	127	127	19	19	2	2
ProcessorTopology.java		0%		0%	45	45	109	109	23	23	1	1
RecordCollectorImpl.java		0%		0%	39	39	97	97	13	13	1	1
StandbyTask.java		0%		0%	38	38	94	94	22	22	1	1
ProcessorContextImpl.java		0%		0%	42	42	117	117	25	25	1	1
ActiveTaskCreator.java		0%		0%	23	23	91	91	13	13	1	1
StreamsProducer.java		0%		0%	31	31	112	112	15	15	1	1
ProcessorRecordContext.java		0%		0%	29	29	85	85	12	12	1	1
RepartitionTopics.java		0%		0%	30	30	82	82	9	9	1	1
ProcessorNode.java		0%		0%	25	25	72	72	16	16	1	1
ChangelogTopics.java		0%		0%	20	20	61	61	8	8	1	1
AbstractTask.java		0%		0%	21	21	60	60	13	13	1	1
AbstractReadWriteDecorator.java		0%		0%	43	43	59	59	38	38	6	6
AbstractReadOnlyDecorator.java		0%		0%	44	44	55	55	39	39	6	6
RecordQueue.java		0%		0%	23	23	59	59	13	13	1	1
StateManagerUtil.java		0%		0%	20	20	52	52	6	6	1	1
GlobalStateUpdateTask.java		0%		0%	10	10	61	61	6	6	1	1
StandbyTaskCreator.java		0%		0%	9	9	43	43	7	7	1	1
StreamsRebalanceListener.java		0%		0%	12	12	46	46	4	4	1	1
ThreadMetadataImpl.java		0%		0%	23	23	33	33	12	12	1	1
ClientUtils.java		0%		0%	23	23	48	48	18	18	3	3
Task.java		0%		0%	16	16	27	27	14	14	3	3
AbstractProcessorContext.java		0%		0%	35	35	61	61	27	27	1	1
WindowedChangelogTopicConfig.java		0%		0%	16	16	30	30	7	7	1	1
PartitionGrouper.java		0%		0%	11	11	28	28	4	4	1	1
RepartitionTopicConfig.java		0%		0%	13	13	24	24	7	7	1	1
InternalTopicConfig.java		0%		0%	11	11	31	31	9	9	1	1
SinkNode.java		0%		n/a	6	6	30	30	6	6	1	1
RecordDeserializer.java		0%		0%	4	4	32	32	3	3	1	1
GlobalProcessorContextImpl.java		0%		0%	17	17	29	29	15	15	1	1
StoreToProcessorContextAdapter.java		0%		0%	24	24	28	28	23	23	1	1
UnwindowedChangelogTopicConfig.java		0%		0%	12	12	20	20	6	6	1	1
TaskMetadataImpl.java		0%		0%	14	14	21	21	9	9	1	1
PunctuationSchedule.java		0%		0%	13	13	28	28	12	12	2	2
QuickUnion.java		0%		0%	10	10	24	24	6	6	1	1
ForwardingDisabledProcessorContext.java		0%		n/a	22	22	26	26	22	22	1	1
PunctuationQueue.java		0%		0%	8	8	24	24	4	4	1	1
SourceNode.java		0%		n/a	8	8	24	24	8	8	1	1
ProcessorAdapter.java		0%		0%	8	8	24	24	6	6	1	1
SerdeGetter.java		0%		0%	9	9	19	19	5	5	1	1
StateRestoreCallbackAdapter.java		0%		0%	7	7	16	16	3	3	1	1
Stamped.java		0%		0%	9	9	15	15	4	4	1	1
TopologyMetadata.java		0%		0%	9	9	13	13	4	4	2	2
ProcessorContextUtils.java		0%		0%	11	11	15	15	7	7	1	1
StaticTopicNameExtractor.java		0%		0%	8	8	12	12	5	5	1	1
DefaultKafkaClientSupplier.java		0%		n/a	6	6	6	6	6	6	1	1
StampedRecord.java		0%		n/a	8	8	9	9	8	8	1	1
DefaultStreamPartitioner.java		0%		n/a	2	2	7	7	2	2	1	1
ToInternal.java		0%		0%	7	7	9	9	6	6	1	1
InternalTopicProperties.java		0%		n/a	4	4	6	6	4	4	1	1
InternalProcessorContext.java		0%		n/a	2	2	3	3	2	2	1	1
RecordBatchingStateRestoreCallback.java		0%		n/a	1	1	1	1	1	1	1	1