KTableImpl

Source file "org/apache/kafka/streams/kstream/internals/KTableImpl.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,931 of 1,9310%76 of 760%1031033663666565
doJoinOnForeignKey(KTable, Function, ValueJoiner, Named, Materialized, boolean)4940%60%44919111
doJoin(KTable, ValueJoiner, Named, MaterializedInternal, boolean, boolean)2170%120%77535311
suppress(Suppressed)1160%80%55202011
doFilter(Predicate, Named, MaterializedInternal, boolean)1040%100%66171711
doMapValues(ValueMapperWithKey, Named, MaterializedInternal)960%80%55171711
doTransformValues(ValueTransformerWithKeySupplier, MaterializedInternal, NamedInternal, String[])900%60%44161611
groupBy(KeyValueMapper, Grouped)620%n/a11101011
enableSendingOldValues(boolean)600%160%99181811
toStream(Named)530%n/a117711
valueGetterSupplier()390%60%449911
buildSuppress(Suppressed, String)340%40%33111111
filterNot(Predicate, Named, Materialized)250%n/a115511
transformValues(ValueTransformerWithKeySupplier, Materialized, Named, String[])230%n/a114411
join(KTable, ValueJoiner, Named, Materialized)210%n/a113311
outerJoin(KTable, ValueJoiner, Named, Materialized)210%n/a113311
leftJoin(KTable, ValueJoiner, Named, Materialized)210%n/a113311
filter(Predicate, Named, Materialized)200%n/a114411
mapValues(ValueMapper, Named, Materialized)200%n/a114411
mapValues(ValueMapperWithKey, Named, Materialized)190%n/a114411
KTableImpl(String, Serde, Serde, Set, String, ProcessorSupplier, GraphNode, InternalStreamsBuilder)180%n/a115511
KTableImpl(String, Serde, Serde, Set, String, ProcessorSupplier, GraphNode, InternalStreamsBuilder)180%n/a115511
transformValues(ValueTransformerWithKeySupplier, Named, String[])140%n/a112211
lambda$doJoinOnForeignKey$3(String)120%n/a111111
lambda$doJoinOnForeignKey$2(String)120%n/a111111
lambda$doJoinOnForeignKey$1(String)120%n/a111111
filter(Predicate)110%n/a112211
filter(Predicate, Named)110%n/a112211
filterNot(Predicate)110%n/a112211
filterNot(Predicate, Named)110%n/a112211
mapValues(ValueMapper)110%n/a112211
mapValues(ValueMapper, Named)110%n/a112211
join(KTable, Function, ValueJoiner)110%n/a113311
join(KTable, Function, ValueJoiner, Named)110%n/a112211
leftJoin(KTable, Function, ValueJoiner)110%n/a113311
leftJoin(KTable, Function, ValueJoiner, Named)110%n/a112211
mapValues(ValueMapperWithKey)100%n/a112211
mapValues(ValueMapperWithKey, Named)100%n/a112211
join(KTable, ValueJoiner)90%n/a111111
join(KTable, ValueJoiner, Named)90%n/a111111
outerJoin(KTable, ValueJoiner, Named)90%n/a111111
leftJoin(KTable, ValueJoiner, Named)90%n/a111111
join(KTable, Function, ValueJoiner, Materialized)90%n/a111111
join(KTable, Function, ValueJoiner, Named, Materialized)90%n/a111111
leftJoin(KTable, Function, ValueJoiner, Named, Materialized)90%n/a111111
leftJoin(KTable, Function, ValueJoiner, Materialized)90%n/a111111
transformValues(ValueTransformerWithKeySupplier, String[])70%n/a111111
transformValues(ValueTransformerWithKeySupplier, Materialized, String[])70%n/a111111
join(KTable, ValueJoiner, Materialized)70%n/a111111
outerJoin(KTable, ValueJoiner, Materialized)70%n/a111111
leftJoin(KTable, ValueJoiner, Materialized)70%n/a111111
groupBy(KeyValueMapper)70%n/a111111
filter(Predicate, Materialized)60%n/a111111
filterNot(Predicate, Materialized)60%n/a111111
mapValues(ValueMapper, Materialized)60%n/a111111
mapValues(ValueMapperWithKey, Materialized)60%n/a111111
toStream(KeyValueMapper, Named)60%n/a111111
outerJoin(KTable, ValueJoiner)60%n/a111111
leftJoin(KTable, ValueJoiner)60%n/a111111
toStream(KeyValueMapper)50%n/a111111
toStream()0%n/a111111
static {...}0%n/a111111
queryableStoreName()0%n/a111111
sendingOldValueEnabled()0%n/a111111
lambda$toStream$0(Object, Change)0%n/a111111
unsafeCastProcessorParametersToCompletelyDifferentType(ProcessorParameters)0%n/a111111