Skip to content

Latest commit

 

History

History
59 lines (42 loc) · 1.69 KB

kafka-streams-KGroupedStreamImpl.adoc

File metadata and controls

59 lines (42 loc) · 1.69 KB
Raw

KGroupedStreamImpl

KGroupedStreamImpl is a concrete AbstractStream and a KGroupedStream.

repartitionIfRequired Internal Method

String repartitionIfRequired(final String queryableStoreName)

repartitionIfRequired…​FIXME

Note
 repartitionIfRequired is used when…​FIXME

aggregate Method

KTable<K, VR> aggregate(
  final Initializer<VR> initializer,
  final Aggregator<? super K, ? super V, VR> aggregator)
KTable<K, VR> aggregate(
  final Initializer<VR> initializer,
  final Aggregator<? super K, ? super V, VR> aggregator,
  final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)
// DEPRECATED ARE NOT LISTED HERE
Note
 aggregate is part of KGroupedStream Contract to…​FIXME.

aggregate…​FIXME

reduce Method

KTable<K, V> reduce(final Reducer<V> reducer)
KTable<K, V> reduce(
  final Reducer<V> reducer,
  final Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized)
// DEPRECATED ARE NOT LISTED HERE
Note
 reduce is part of KGroupedStream Contract to…​FIXME.

reduce…​FIXME

windowedBy Method

SessionWindowedKStream<K, V> windowedBy(final SessionWindows windows)
<W extends Window> TimeWindowedKStream<K, V> windowedBy(final Windows<W> windows)
Note
 windowedBy is part of KGroupedStream Contract to…​FIXME.

windowedBy…​FIXME