Skip to content

Latest commit

 

History

History
33 lines (24 loc) · 747 Bytes

kafka-streams-KGroupedTableImpl.adoc

File metadata and controls

33 lines (24 loc) · 747 Bytes
Raw

KGroupedTableImpl

KGroupedTableImpl is…​FIXME

buildAggregate Internal Method

void buildAggregate(
  final ProcessorSupplier<K, Change<V>> aggregateSupplier,
  final String topic,
  final String funcName,
  final String sourceName,
  final String sinkName)

buildAggregate…​FIXME

Note
 buildAggregate is used when…​FIXME

doAggregate Internal Method

<T> KTable<K, T> doAggregate(
  final ProcessorSupplier<K, Change<V>> aggregateSupplier,
  final String functionName,
  final MaterializedInternal<K, T, KeyValueStore<Bytes, byte[]>> materialized)

doAggregate…​FIXME

Note
 doAggregate is used when…​FIXME