org.apache.kafka.streams.kstream.internals

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total18,674 of 18,6740%1,054 of 1,0540%1,4081,4083,7403,740881881155155
KStreamImpl.java2,6650%760%14314345645610510511
KTableImpl.java1,9310%760%103103366366656511
KStreamSlidingWindowAggregate.java1,2000%1000%7575228228252544
InternalStreamsBuilder.java1,1790%1040%8787258258353522
KStreamImplJoin.java7700%620%4545149149141422
CogroupedStreamAggregateBuilder.java5420%180%18181031039911
KStreamKStreamJoin.java4660%320%252590909922
SessionWindowedKStreamImpl.java4650%300%35358585202011
TimeWindowedKStreamImpl.java4470%300%32327979171711
SlidingWindowedKStreamImpl.java4440%280%31317777171711
KStreamSessionWindowAggregate.java4180%120%22227777161644
KGroupedTableImpl.java3750%160%25256767171711
KStreamWindowAggregate.java3600%100%19196868141444
KGroupedStreamImpl.java3580%120%23235757171711
KTableTransformValues.java2970%180%24246262151544
KTableKTableOuterJoin.java2730%260%27276767141444
KTableFilter.java2710%280%31316161171744
KTableKTableLeftJoin.java2550%180%23236262141444
KTableKTableInnerJoin.java2500%140%22226161151544
KTableMapValues.java2410%180%26265656171744
KTableKTableRightJoin.java2360%100%19195757141444
KStreamAggregate.java2220%80%18184343141444
BranchedKStreamImpl.java2160%80%131340409911
KStreamReduce.java2120%80%18184141141444
KTableSource.java2060%120%16164242101022
SlidingWindowedCogroupedKStreamImpl.java2000%120%121240406611
KTableKTableJoinMerger.java1990%100%18183838131333
TimeWindowedCogroupedKStreamImpl.java1920%120%121240406611
SessionWindowedCogroupedKStreamImpl.java1920%120%121240406611
AbstractStream.java1910%60%25254444222233
KTableAggregate.java1780%140%141438387722
KTableRepartitionMap.java1760%200%23233232131344
CogroupedKStreamImpl.java1690%n/a10102626101011
GroupedStreamAggregateBuilder.java1670%180%161631317711
KTableReduce.java1670%120%131334347722
WrappingNullableUtils.java1290%180%21213535121211
KStreamKTableJoinProcessor.java1130%80%9923235511
FullChangeSerde.java1130%160%141427276611
ChangedSerializer.java1020%100%111121216611
TimestampedTupleForwarder.java980%120%111121215511
KTablePassThrough.java910%20%13131919121244
TimestampedCacheFlushListener.java910%20%5523234411
NamedInternal.java810%60%121221219911
KStreamBranch.java770%60%7713134422
Change.java730%100%9913134411
ChangedDeserializer.java710%40%8815156611
PrintForeachAction.java700%80%7715153311
MaterializedInternal.java670%100%16161818111111
KStreamFlatTransformValues.java650%40%9920207722
SessionCacheFlushListener.java640%n/a3314143311
KStreamFlatTransform.java630%40%9919197722
TimeWindow.java530%80%66992211
TimestampedKeyValueStoreMaterializer.java520%60%5516162211
ConsumedInternal.java510%40%12121313101011
TransformerSupplierAdapter.java500%20%8814147722
WrappingNullableSerde.java500%n/a6617176611
KStreamFlatMap.java500%20%5511114422
KStreamTransformValues.java480%n/a7715157722
KStreamJoinWindow.java460%20%6612125522
KStreamFlatMapValues.java450%20%5510104422
KTableSourceValueGetterSupplier.java440%n/a6610106622
SessionWindow.java440%60%55772211
KTableMaterializedValueGetterSupplier.java410%n/a66996622
KTableKTableAbstractJoinValueGetterSupplier.java400%n/a2210102211
KStreamMap.java390%n/a44994422
SessionTupleForwarder.java390%40%44882211
KStreamFilter.java390%20%55994422
KStreamPrint.java380%20%6610105522
KTableKTableAbstractJoin.java380%n/a2212122211
KStreamMapValues.java340%n/a44884422
StreamJoinedInternal.java310%n/a10101111101011
KStreamPeek.java310%n/a44884422
KStreamKTableJoin.java300%n/a33773311
KStreamGlobalKTableJoin.java280%n/a22772211
UnlimitedWindow.java270%20%33662211
RepartitionedInternal.java250%n/a77887711
PrintedInternal.java250%20%44443311
BranchedInternal.java230%n/a66886611
WindowedStreamPartitioner.java0%n/a22552211
ProducedInternal.java0%n/a55665511
JoinedInternal.java0%n/a55665511
GlobalKTableImpl.java0%n/a33663311
FullTimeWindowedSerde.java0%n/a11441111
GroupedInternal.java0%n/a44554411
PassThrough.java0%n/a33443322
JoinWindowsInternal.java0%n/a22332211
KTableValueGetter.java0%n/a11111111