| KStreamImpl.java |  | 0% |  | 0% | 143 | 143 | 456 | 456 | 105 | 105 | 1 | 1 |
| KTableImpl.java |  | 0% |  | 0% | 103 | 103 | 366 | 366 | 65 | 65 | 1 | 1 |
| KStreamSlidingWindowAggregate.java |  | 0% |  | 0% | 75 | 75 | 228 | 228 | 25 | 25 | 4 | 4 |
| InternalStreamsBuilder.java |  | 0% |  | 0% | 87 | 87 | 258 | 258 | 35 | 35 | 2 | 2 |
| KStreamImplJoin.java |  | 0% |  | 0% | 45 | 45 | 149 | 149 | 14 | 14 | 2 | 2 |
| CogroupedStreamAggregateBuilder.java |  | 0% |  | 0% | 18 | 18 | 103 | 103 | 9 | 9 | 1 | 1 |
| KStreamKStreamJoin.java |  | 0% |  | 0% | 25 | 25 | 90 | 90 | 9 | 9 | 2 | 2 |
| SessionWindowedKStreamImpl.java |  | 0% |  | 0% | 35 | 35 | 85 | 85 | 20 | 20 | 1 | 1 |
| TimeWindowedKStreamImpl.java |  | 0% |  | 0% | 32 | 32 | 79 | 79 | 17 | 17 | 1 | 1 |
| SlidingWindowedKStreamImpl.java |  | 0% |  | 0% | 31 | 31 | 77 | 77 | 17 | 17 | 1 | 1 |
| KStreamSessionWindowAggregate.java |  | 0% |  | 0% | 22 | 22 | 77 | 77 | 16 | 16 | 4 | 4 |
| KGroupedTableImpl.java |  | 0% |  | 0% | 25 | 25 | 67 | 67 | 17 | 17 | 1 | 1 |
| KStreamWindowAggregate.java |  | 0% |  | 0% | 19 | 19 | 68 | 68 | 14 | 14 | 4 | 4 |
| KGroupedStreamImpl.java |  | 0% |  | 0% | 23 | 23 | 57 | 57 | 17 | 17 | 1 | 1 |
| KTableTransformValues.java |  | 0% |  | 0% | 24 | 24 | 62 | 62 | 15 | 15 | 4 | 4 |
| KTableKTableOuterJoin.java |  | 0% |  | 0% | 27 | 27 | 67 | 67 | 14 | 14 | 4 | 4 |
| KTableFilter.java |  | 0% |  | 0% | 31 | 31 | 61 | 61 | 17 | 17 | 4 | 4 |
| KTableKTableLeftJoin.java |  | 0% |  | 0% | 23 | 23 | 62 | 62 | 14 | 14 | 4 | 4 |
| KTableKTableInnerJoin.java |  | 0% |  | 0% | 22 | 22 | 61 | 61 | 15 | 15 | 4 | 4 |
| KTableMapValues.java |  | 0% |  | 0% | 26 | 26 | 56 | 56 | 17 | 17 | 4 | 4 |
| KTableKTableRightJoin.java |  | 0% |  | 0% | 19 | 19 | 57 | 57 | 14 | 14 | 4 | 4 |
| KStreamAggregate.java |  | 0% |  | 0% | 18 | 18 | 43 | 43 | 14 | 14 | 4 | 4 |
| BranchedKStreamImpl.java |  | 0% |  | 0% | 13 | 13 | 40 | 40 | 9 | 9 | 1 | 1 |
| KStreamReduce.java |  | 0% |  | 0% | 18 | 18 | 41 | 41 | 14 | 14 | 4 | 4 |
| KTableSource.java |  | 0% |  | 0% | 16 | 16 | 42 | 42 | 10 | 10 | 2 | 2 |
| SlidingWindowedCogroupedKStreamImpl.java |  | 0% |  | 0% | 12 | 12 | 40 | 40 | 6 | 6 | 1 | 1 |
| KTableKTableJoinMerger.java |  | 0% |  | 0% | 18 | 18 | 38 | 38 | 13 | 13 | 3 | 3 |
| TimeWindowedCogroupedKStreamImpl.java |  | 0% |  | 0% | 12 | 12 | 40 | 40 | 6 | 6 | 1 | 1 |
| SessionWindowedCogroupedKStreamImpl.java |  | 0% |  | 0% | 12 | 12 | 40 | 40 | 6 | 6 | 1 | 1 |
| AbstractStream.java |  | 0% |  | 0% | 25 | 25 | 44 | 44 | 22 | 22 | 3 | 3 |
| KTableAggregate.java |  | 0% |  | 0% | 14 | 14 | 38 | 38 | 7 | 7 | 2 | 2 |
| KTableRepartitionMap.java |  | 0% |  | 0% | 23 | 23 | 32 | 32 | 13 | 13 | 4 | 4 |
| CogroupedKStreamImpl.java |  | 0% | | n/a | 10 | 10 | 26 | 26 | 10 | 10 | 1 | 1 |
| GroupedStreamAggregateBuilder.java |  | 0% |  | 0% | 16 | 16 | 31 | 31 | 7 | 7 | 1 | 1 |
| KTableReduce.java |  | 0% |  | 0% | 13 | 13 | 34 | 34 | 7 | 7 | 2 | 2 |
| WrappingNullableUtils.java |  | 0% |  | 0% | 21 | 21 | 35 | 35 | 12 | 12 | 1 | 1 |
| KStreamKTableJoinProcessor.java |  | 0% |  | 0% | 9 | 9 | 23 | 23 | 5 | 5 | 1 | 1 |
| FullChangeSerde.java |  | 0% |  | 0% | 14 | 14 | 27 | 27 | 6 | 6 | 1 | 1 |
| ChangedSerializer.java |  | 0% |  | 0% | 11 | 11 | 21 | 21 | 6 | 6 | 1 | 1 |
| TimestampedTupleForwarder.java |  | 0% |  | 0% | 11 | 11 | 21 | 21 | 5 | 5 | 1 | 1 |
| KTablePassThrough.java |  | 0% |  | 0% | 13 | 13 | 19 | 19 | 12 | 12 | 4 | 4 |
| TimestampedCacheFlushListener.java |  | 0% |  | 0% | 5 | 5 | 23 | 23 | 4 | 4 | 1 | 1 |
| NamedInternal.java |  | 0% |  | 0% | 12 | 12 | 21 | 21 | 9 | 9 | 1 | 1 |
| KStreamBranch.java |  | 0% |  | 0% | 7 | 7 | 13 | 13 | 4 | 4 | 2 | 2 |
| Change.java |  | 0% |  | 0% | 9 | 9 | 13 | 13 | 4 | 4 | 1 | 1 |
| ChangedDeserializer.java |  | 0% |  | 0% | 8 | 8 | 15 | 15 | 6 | 6 | 1 | 1 |
| PrintForeachAction.java |  | 0% |  | 0% | 7 | 7 | 15 | 15 | 3 | 3 | 1 | 1 |
| MaterializedInternal.java |  | 0% |  | 0% | 16 | 16 | 18 | 18 | 11 | 11 | 1 | 1 |
| KStreamFlatTransformValues.java |  | 0% |  | 0% | 9 | 9 | 20 | 20 | 7 | 7 | 2 | 2 |
| SessionCacheFlushListener.java |  | 0% | | n/a | 3 | 3 | 14 | 14 | 3 | 3 | 1 | 1 |
| KStreamFlatTransform.java |  | 0% |  | 0% | 9 | 9 | 19 | 19 | 7 | 7 | 2 | 2 |
| TimeWindow.java |  | 0% |  | 0% | 6 | 6 | 9 | 9 | 2 | 2 | 1 | 1 |
| TimestampedKeyValueStoreMaterializer.java |  | 0% |  | 0% | 5 | 5 | 16 | 16 | 2 | 2 | 1 | 1 |
| ConsumedInternal.java |  | 0% |  | 0% | 12 | 12 | 13 | 13 | 10 | 10 | 1 | 1 |
| TransformerSupplierAdapter.java |  | 0% |  | 0% | 8 | 8 | 14 | 14 | 7 | 7 | 2 | 2 |
| WrappingNullableSerde.java |  | 0% | | n/a | 6 | 6 | 17 | 17 | 6 | 6 | 1 | 1 |
| KStreamFlatMap.java |  | 0% |  | 0% | 5 | 5 | 11 | 11 | 4 | 4 | 2 | 2 |
| KStreamTransformValues.java |  | 0% | | n/a | 7 | 7 | 15 | 15 | 7 | 7 | 2 | 2 |
| KStreamJoinWindow.java |  | 0% |  | 0% | 6 | 6 | 12 | 12 | 5 | 5 | 2 | 2 |
| KStreamFlatMapValues.java |  | 0% |  | 0% | 5 | 5 | 10 | 10 | 4 | 4 | 2 | 2 |
| KTableSourceValueGetterSupplier.java |  | 0% | | n/a | 6 | 6 | 10 | 10 | 6 | 6 | 2 | 2 |
| SessionWindow.java |  | 0% |  | 0% | 5 | 5 | 7 | 7 | 2 | 2 | 1 | 1 |
| KTableMaterializedValueGetterSupplier.java |  | 0% | | n/a | 6 | 6 | 9 | 9 | 6 | 6 | 2 | 2 |
| KTableKTableAbstractJoinValueGetterSupplier.java |  | 0% | | n/a | 2 | 2 | 10 | 10 | 2 | 2 | 1 | 1 |
| KStreamMap.java |  | 0% | | n/a | 4 | 4 | 9 | 9 | 4 | 4 | 2 | 2 |
| SessionTupleForwarder.java |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 2 | 2 | 1 | 1 |
| KStreamFilter.java |  | 0% |  | 0% | 5 | 5 | 9 | 9 | 4 | 4 | 2 | 2 |
| KStreamPrint.java |  | 0% |  | 0% | 6 | 6 | 10 | 10 | 5 | 5 | 2 | 2 |
| KTableKTableAbstractJoin.java |  | 0% | | n/a | 2 | 2 | 12 | 12 | 2 | 2 | 1 | 1 |
| KStreamMapValues.java |  | 0% | | n/a | 4 | 4 | 8 | 8 | 4 | 4 | 2 | 2 |
| StreamJoinedInternal.java |  | 0% | | n/a | 10 | 10 | 11 | 11 | 10 | 10 | 1 | 1 |
| KStreamPeek.java |  | 0% | | n/a | 4 | 4 | 8 | 8 | 4 | 4 | 2 | 2 |
| KStreamKTableJoin.java |  | 0% | | n/a | 3 | 3 | 7 | 7 | 3 | 3 | 1 | 1 |
| KStreamGlobalKTableJoin.java |  | 0% | | n/a | 2 | 2 | 7 | 7 | 2 | 2 | 1 | 1 |
| UnlimitedWindow.java |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 2 | 2 | 1 | 1 |
| RepartitionedInternal.java |  | 0% | | n/a | 7 | 7 | 8 | 8 | 7 | 7 | 1 | 1 |
| PrintedInternal.java |  | 0% |  | 0% | 4 | 4 | 4 | 4 | 3 | 3 | 1 | 1 |
| BranchedInternal.java |  | 0% | | n/a | 6 | 6 | 8 | 8 | 6 | 6 | 1 | 1 |
| WindowedStreamPartitioner.java | | 0% | | n/a | 2 | 2 | 5 | 5 | 2 | 2 | 1 | 1 |
| ProducedInternal.java | | 0% | | n/a | 5 | 5 | 6 | 6 | 5 | 5 | 1 | 1 |
| JoinedInternal.java | | 0% | | n/a | 5 | 5 | 6 | 6 | 5 | 5 | 1 | 1 |
| GlobalKTableImpl.java | | 0% | | n/a | 3 | 3 | 6 | 6 | 3 | 3 | 1 | 1 |
| FullTimeWindowedSerde.java | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 | 1 | 1 |
| GroupedInternal.java | | 0% | | n/a | 4 | 4 | 5 | 5 | 4 | 4 | 1 | 1 |
| PassThrough.java | | 0% | | n/a | 3 | 3 | 4 | 4 | 3 | 3 | 2 | 2 |
| JoinWindowsInternal.java | | 0% | | n/a | 2 | 2 | 3 | 3 | 2 | 2 | 1 | 1 |
| KTableValueGetter.java | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 1 | 1 |