...
| Code Block | ||||
|---|---|---|---|---|
| ||||
<W extends Window> WindowedKStream<K, V> windowedBy(Windows<W> timeWindows);
SessionWindowedKStream<K, V> sessionWindowedBy(SessionWindows sessionWindows);
KTable<K, Long> count(final Materialized materialized);
KTable<K, V> reduce(final Reducer<V> reducer, final Materialized<K, V, KeyValueStore<K, V>> materialized);
<VR> KTable<K, VR> aggregate(final Initializer<VR> initializer,
final Aggregator<? super K, ? super V, VR> aggregator,
final Serde<VR> aggValueSerde,
final Materialized<K, V, KeyValueStore<K, V>> materialized); |
| Code Block | ||||
|---|---|---|---|---|
| ||||
KTable<K, Long> count(final Materialized<K, V, KeyValueStore<K, V>> materialized);
KTable<K, V> reduce(final Reducer<V> adder, final Reducer<V> subtractor, final Materialized<K, V, KeyValueStore<K, V>> materialized);
<VR> KTable<K, VR> aggregate(final Initializer<VR> initializer,
final Aggregator<? super K, ? super V, VR> aggregator,
final Aggregator<? super K, ? super V, VR> subtractor,
final Materialized<K, V, KeyValueStore<K, V>> materialized); |
New classes and interfaces:
...