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 exclusively when KGroupedTableImpl is requested to doAggregate.

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 KGroupedTableImpl is requested to reduce, count and aggregate.

reduce Method

KTable<K, V> reduce(
  final Reducer<V> adder,
  final Reducer<V> subtractor,
  final Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized)
Note
 reduce is part of the KGroupedTable Contract to…​FIXME.

reduce…​FIXME

count Method

KTable<K, Long> count(final Materialized<K, Long, KeyValueStore<Bytes, byte[]>> materialized)
Note
 count is part of the KGroupedTable Contract to…​FIXME.

count…​FIXME

aggregate Method

KTable<K, VR> aggregate(
  final Initializer<VR> initializer,
  final Aggregator<? super K, ? super V, VR> adder,
  final Aggregator<? super K, ? super V, VR> subtractor,
  final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)
Note
 aggregate is part of the KGroupedTable Contract to…​FIXME.

aggregate…​FIXME

createRepartitionNode Internal Method

GroupedTableOperationRepartitionNode<K, V> createRepartitionNode(
  final String sinkName,
  final String sourceName,
  final String topic)

createRepartitionNode…​FIXME

Note
 createRepartitionNode is used exclusively when KGroupedTableImpl is requested to doAggregate (when requested to reduce, count and aggregate).

results matching ""

    No results matching ""