StreamsBuilder builder = new StreamsBuilder();
builder
- .<Word, WordCount>stream(inputTopic)
- .map((word, wordCount) ->
+ .<Word, Counter>stream(inputTopic)
+ .map((word, counter) ->
{
- Entry entry = Entry.of(word.getWord(), wordCount.getCount());
+ Entry entry = Entry.of(word.getWord(), counter.getCounter());
return new KeyValue<>(word.getUser(), entry);
})
.groupByKey()