Page History

...

• KTable<K, Long> count(final String storeName);

• KTable<K, V> reduce(final Reducer<V> adder, final Reducer<V> subtractor);

• <VR> KTable<K, VR> aggregate(final Initializer<VR> initializer, final Aggregator<? super K, ? super V, VR> adder, final Aggregator<? super K, ? super V, VR> subtractor)

In KGroupedStream.java:

• KTable<K, Long> count(final String storeName);

• KTable<K, V> reduce(final Reducer<V> reducer);

• <VR> KTable<K, VR> aggregate(final Initializer<VR> initializer, final Aggregator<? super K, ? super V, VR> aggregator, final Serde<VR> aggValueSerde);

Remove unnecessary methods

...