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
KStreamImpl2,6650%760%14314345645610510511
KTableImpl1,9310%760%103103366366656511
InternalStreamsBuilder1,1710%1040%8585257257333311
KStreamSlidingWindowAggregate.KStreamSlidingWindowAggregateProcessor1,1090%1000%6363207207131311
KStreamImplJoin7320%620%40401371379911
CogroupedStreamAggregateBuilder5420%180%18181031039911
SessionWindowedKStreamImpl4650%300%35358585202011
TimeWindowedKStreamImpl4470%300%32327979171711
SlidingWindowedKStreamImpl4440%280%31317777171711
KStreamKStreamJoin.KStreamKStreamJoinProcessor4080%300%212173736611
KGroupedTableImpl3750%160%25256767171711
KGroupedStreamImpl3580%120%23235757171711
KStreamSessionWindowAggregate.KStreamSessionWindowAggregateProcessor3040%120%9952523311
KStreamWindowAggregate.KStreamWindowAggregateProcessor2680%100%8847473311
BranchedKStreamImpl2160%80%131340409911
SlidingWindowedCogroupedKStreamImpl2000%120%121240406611
SessionWindowedCogroupedKStreamImpl1920%120%121240406611
TimeWindowedCogroupedKStreamImpl1920%120%121240406611
CogroupedKStreamImpl1690%n/a10102626101011
GroupedStreamAggregateBuilder1670%180%161631317711
KTableSource.KTableSourceProcessor1570%100%8827273311
AbstractStream1480%60%18183636151511
KStreamAggregate.KStreamAggregateProcessor1450%80%7726263311
KTableAggregate.KTableAggregateProcessor1430%140%101027273311
KTableKTableOuterJoin.KTableKTableOuterJoinProcessor1430%180%131332324411
KTableKTableLeftJoin.KTableKTableLeftJoinProcessor1390%140%111133334411
KStreamReduce.KStreamReduceProcessor1380%80%7725253311
KTableReduce.KTableReduceProcessor1350%120%9924243311
WrappingNullableUtils1290%180%21213535121211
KTableKTableInnerJoin.KTableKTableJoinProcessor1280%100%9930304411
KTableFilter.KTableFilterProcessor1230%140%111123234411
KTableKTableRightJoin.KTableKTableRightJoinProcessor1200%60%7728284411
KTableTransformValues.KTableTransformValuesProcessor1170%80%8821214411
FullChangeSerde1130%160%141427276611
KStreamKTableJoinProcessor1130%80%9923235511
KTableMapValues.KTableMapValuesProcessor1030%80%8819194411
ChangedSerializer1020%100%111121216611
TimestampedTupleForwarder980%120%111121215511
KTableFilter960%140%131327276611
TimestampedCacheFlushListener910%20%5523234411
KTableTransformValues.KTableTransformValuesGetter880%40%6620204411
KTableKTableJoinMerger.KTableKTableJoinMergeProcessor870%80%7714143311
KTableMapValues860%100%111126266611
KTableKTableOuterJoin.KTableKTableOuterJoinValueGetter830%80%8826264411
NamedInternal810%60%121221219911
KTableRepartitionMap.KTableMapProcessor800%180%111110102211
Change730%100%9913134411
ChangedDeserializer710%40%8815156611
KTableKTableInnerJoin.KTableKTableInnerJoinValueGetter700%40%6621214411
PrintForeachAction700%80%7715153311
KTableKTableRightJoin.KTableKTableRightJoinValueGetter690%40%6620204411
KTableKTableLeftJoin.KTableKTableLeftJoinValueGetter690%40%6620204411
MaterializedInternal670%100%16161818111111
KTableKTableJoinMerger650%20%8817177711
SessionCacheFlushListener640%n/a3314143311
KTableTransformValues630%60%7716164411
KStreamBranch.KStreamBranchProcessor620%60%55882211
KStreamSessionWindowAggregate610%n/a7717177711
KStreamKStreamJoin580%20%4417173311
TimeWindow530%80%66992211
TimestampedKeyValueStoreMaterializer520%60%5516162211
ConsumedInternal510%40%12121313101011
WrappingNullableSerde500%n/a6617176611
KTableSource490%20%8815157711
KStreamFlatTransformValues.KStreamFlatTransformValuesProcessor480%40%6615154411
KTableKTableJoinMerger.new KTableValueGetterSupplier() {...}470%n/a33883311
KStreamFlatTransform.KStreamFlatTransformProcessor460%40%6614144411
SessionWindow440%60%55772211
KTableRepartitionMap.KTableMapValueGetter430%20%5512124411
KStreamWindowAggregate410%n/a5513135511
KStreamSlidingWindowAggregate410%n/a5513135511
KTableKTableAbstractJoinValueGetterSupplier400%n/a2210102211
SessionTupleForwarder390%40%44882211
KTableKTableAbstractJoin380%n/a2212122211
KStreamImplJoin.TimeTracker380%n/a5512125511
KStreamFlatMap.KStreamFlatMapProcessor380%20%33772211
KTablePassThrough360%20%5510104411
TransformerSupplierAdapter.new Transformer() {...}350%20%5510104411
KTableAggregate350%n/a4411114411
KStreamAggregate340%n/a5511115511
KStreamJoinWindow.KStreamJoinWindowProcessor340%20%44883311
KStreamFlatMapValues.KStreamFlatMapValuesProcessor330%20%33662211
KTableReduce320%n/a4410104411
KTableKTableInnerJoin320%n/a55665511
KStreamTransformValues.KStreamTransformValuesProcessor310%n/a4410104411
KStreamReduce310%n/a5510105511
StreamJoinedInternal310%n/a10101111101011
KStreamSessionWindowAggregate.KTableSessionWindowValueGetter310%n/a33663311
KTableRepartitionMap300%n/a44884411
KStreamKTableJoin300%n/a33773311
KStreamWindowAggregate.KStreamWindowAggregateValueGetter290%n/a33663311
KTableTransformValues.new KTableValueGetterSupplier() {...}290%n/a33663311
KStreamGlobalKTableJoin280%n/a22772211
KStreamSlidingWindowAggregate.KStreamWindowAggregateValueGetter280%n/a44664411
KTableMapValues.KTableMapValuesValueGetter270%n/a44884411
KTableKTableRightJoin270%n/a44554411
KTableKTableLeftJoin270%n/a44554411
KTableKTableOuterJoin270%n/a44554411
KTableFilter.KTableFilterValueGetter270%n/a44884411
KStreamMap.KStreamMapProcessor270%n/a22552211
UnlimitedWindow270%20%33662211
KStreamPrint.KStreamPrintProcessor260%20%44663311
RepartitionedInternal250%n/a77887711
PrintedInternal250%20%44443311
KTableMapValues.new KTableValueGetterSupplier() {...}250%n/a33443311
KTableFilter.new KTableValueGetterSupplier() {...}250%n/a33443311
KTableSourceValueGetterSupplier.KTableSourceValueGetter240%n/a33553311
KStreamFilter.KStreamFilterProcessor240%20%33442211
KTableRepartitionMap.new KTableValueGetterSupplier() {...}230%n/a33333311
AbstractStream.1.new ValueTransformerWithKey() {...}230%n/a44664411
BranchedInternal230%n/a66886611
KTablePassThrough.new KTableValueGetterSupplier() {...}0%n/a33333311
KStreamSessionWindowAggregate.new KTableValueGetterSupplier() {...}0%n/a33333311
KStreamSlidingWindowAggregate.new KTableValueGetterSupplier() {...}0%n/a33333311
KStreamReduce.new KTableValueGetterSupplier() {...}0%n/a33333311
KStreamAggregate.new KTableValueGetterSupplier() {...}0%n/a33333311
KStreamMapValues.KStreamMapProcessor0%n/a22442211
KStreamWindowAggregate.new KTableValueGetterSupplier() {...}0%n/a33333311
KTableMaterializedValueGetterSupplier.KTableMaterializedValueGetter0%n/a33443311
KTablePassThrough.KTablePassThroughValueGetter0%n/a33443311
KStreamReduce.KStreamReduceValueGetter0%n/a33443311
KStreamAggregate.KStreamAggregateValueGetter0%n/a33443311
KTableKTableLeftJoin.KTableKTableLeftJoinValueGetterSupplier0%n/a22442211
KTableSourceValueGetterSupplier0%n/a33553311
KTableKTableOuterJoin.KTableKTableOuterJoinValueGetterSupplier0%n/a22442211
KTableKTableRightJoin.KTableKTableRightJoinValueGetterSupplier0%n/a22442211
KTableMaterializedValueGetterSupplier0%n/a33553311
KTableKTableInnerJoin.KTableKTableInnerJoinValueGetterSupplier0%n/a22442211
AbstractStream.new ValueTransformerWithKeySupplier() {...}0%n/a33443311
KStreamPeek.KStreamPeekProcessor0%n/a22442211
WindowedStreamPartitioner0%n/a22552211
KStreamTransformValues0%n/a33553311
KStreamFlatTransform0%n/a33553311
KStreamFlatTransformValues0%n/a33553311
JoinedInternal0%n/a55665511
ProducedInternal0%n/a55665511
KStreamFilter0%n/a22552211
KStreamBranch0%n/a22552211
TransformerSupplierAdapter0%n/a33553311
GlobalKTableImpl0%n/a33663311
FullTimeWindowedSerde0%n/a11441111
GroupedInternal0%n/a44554411
KTablePassThrough.KTablePassThroughProcessor0%n/a22332211
KStreamMap0%n/a22442211
KStreamJoinWindow0%n/a22442211
KStreamFlatMap0%n/a22442211
KStreamPeek0%n/a22442211
KStreamFlatMapValues0%n/a22442211
KStreamPrint0%n/a22442211
KStreamMapValues0%n/a22442211
PassThrough0%n/a22222211
InternalStreamsBuilder.new GraphNode() {...}0%n/a22222211
JoinWindowsInternal0%n/a22332211
PassThrough.PassThroughProcessor0%n/a11221111
KTableValueGetter0%n/a11111111