Source file "org/apache/kafka/streams/kstream/internals/KStreamImpl.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 2,665 of 2,665 | 0% | 76 of 76 | 0% | 143 | 143 | 456 | 456 | 105 | 105 |
| doBranch(NamedInternal, Predicate[]) | | 0% | | 0% | 5 | 5 | 21 | 21 | 1 | 1 |
| toTable(Named, Materialized) | | 0% | | 0% | 4 | 4 | 26 | 26 | 1 | 1 |
| createRepartitionedSource(InternalStreamsBuilder, Serde, Serde, String, StreamPartitioner, BaseRepartitionNode.BaseRepartitionNodeBuilder) | | 0% | | 0% | 3 | 3 | 22 | 22 | 1 | 1 |
| doRepartition(Repartitioned) | | 0% | | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
| doStreamTableJoin(KTable, ValueJoinerWithKey, Joined, boolean) | | 0% | | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
| doJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined, KStreamImplJoin) | | 0% | | 0% | 3 | 3 | 18 | 18 | 1 | 1 |
| merge(InternalStreamsBuilder, KStream, NamedInternal) | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| flatTransform(TransformerSupplier, Named, String[]) | | 0% | | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
| globalTableJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, boolean, Named) | | 0% | n/a | 1 | 1 | 12 | 12 | 1 | 1 | |
| doFlatTransformValues(ValueTransformerWithKeySupplier, Named, String[]) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| doTransformValues(ValueTransformerWithKeySupplier, NamedInternal, String[]) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| repartitionForJoin(String, Serde, Serde) | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| process(ProcessorSupplier, Named, String[]) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| process(ProcessorSupplier, Named, String[]) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| mapValues(ValueMapperWithKey, Named) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| flatMapValues(ValueMapperWithKey, Named) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| filter(Predicate, Named) | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| filterNot(Predicate, Named) | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| map(KeyValueMapper, Named) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| flatMap(KeyValueMapper, Named) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| peek(ForeachAction, Named) | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| through(String, Produced) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| join(KTable, ValueJoinerWithKey, Joined) | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| leftJoin(KTable, ValueJoinerWithKey, Joined) | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| groupBy(KeyValueMapper, Grouped) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| print(Printed) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| selectKey(KeyValueMapper, Named) | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| foreach(ForeachAction, Named) | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| to(String, Produced) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| to(TopicNameExtractor, Produced) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| internalSelectKey(KeyValueMapper, NamedInternal) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| to(TopicNameExtractor, ProducedInternal) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| groupByKey(Grouped) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| join(KTable, ValueJoiner, Joined) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| leftJoin(KTable, ValueJoiner, Joined) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| transform(TransformerSupplier, String[]) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| merge(KStream, Named) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| transformValues(ValueTransformerSupplier, Named, String[]) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| transformValues(ValueTransformerWithKeySupplier, Named, String[]) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| flatTransform(TransformerSupplier, String[]) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| split(Named) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| leftJoin(KStream, ValueJoiner, JoinWindows, StreamJoined) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| join(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| outerJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| transform(TransformerSupplier, Named, String[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| KStreamImpl(String, Serde, Serde, Set, boolean, GraphNode, InternalStreamsBuilder) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| branch(Named, Predicate[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| transformValues(ValueTransformerSupplier, String[]) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| flatTransformValues(ValueTransformerSupplier, String[]) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| flatTransformValues(ValueTransformerSupplier, Named, String[]) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| through(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| to(String) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| to(TopicNameExtractor) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| join(KStream, ValueJoinerWithKey, JoinWindows) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(KStream, ValueJoinerWithKey, JoinWindows) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| outerJoin(KStream, ValueJoinerWithKey, JoinWindows) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| transformValues(ValueTransformerWithKeySupplier, String[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| flatTransformValues(ValueTransformerWithKeySupplier, String[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| flatTransformValues(ValueTransformerWithKeySupplier, Named, String[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| process(ProcessorSupplier, String[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| process(ProcessorSupplier, String[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| toTable() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| toTable(Named) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| join(KTable, ValueJoinerWithKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(KTable, ValueJoinerWithKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$internalSelectKey$0(KeyValueMapper, Object, Object) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| split() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| groupBy(KeyValueMapper) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| groupByKey() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| join(KStream, ValueJoiner, JoinWindows, StreamJoined) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| outerJoin(KStream, ValueJoiner, JoinWindows, StreamJoined) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| join(GlobalKTable, KeyValueMapper, ValueJoinerWithKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| join(GlobalKTable, KeyValueMapper, ValueJoiner, Named) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| join(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, Named) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(GlobalKTable, KeyValueMapper, ValueJoiner, Named) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, Named) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| join(KStream, ValueJoiner, JoinWindows) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(KStream, ValueJoiner, JoinWindows) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| outerJoin(KStream, ValueJoiner, JoinWindows) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| join(GlobalKTable, KeyValueMapper, ValueJoiner) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(GlobalKTable, KeyValueMapper, ValueJoiner) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| mapValues(ValueMapper, Named) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| flatMapValues(ValueMapper, Named) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| join(KTable, ValueJoiner) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| leftJoin(KTable, ValueJoiner) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$createRepartitionedSource$2(Object, Object) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| filter(Predicate) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| filterNot(Predicate) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| selectKey(KeyValueMapper) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| map(KeyValueMapper) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| mapValues(ValueMapper) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| mapValues(ValueMapperWithKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| flatMap(KeyValueMapper) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| flatMapValues(ValueMapper) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| flatMapValues(ValueMapperWithKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| foreach(ForeachAction) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| peek(ForeachAction) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| branch(Predicate[]) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| merge(KStream) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| repartition() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| toTable(Materialized) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$foreach$1(ForeachAction) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| repartition(Repartitioned) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |