projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 4aef1e6) | patch
popular: 1.2.0 - Refined `WindowedWord` (timestamp as string) popular-1.2.0
authorKai Moritz <kai@juplo.de>
Sat, 22 Jun 2024 09:23:25 +0000 (11:23 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 22 Jun 2024 11:12:36 +0000 (13:12 +0200)
commitdc7be5b9ac6d8b441039f8503b61652e74f4faee
tree79b14baf59a89c98a6a1735f17e0a989f189a2e4tree | snapshot
parent4aef1e64a08772a8707645d46e7bd1eb3ad9fad7commit | diff
popular: 1.2.0 - Refined `WindowedWord` (timestamp as string)

* `WindowedWord` only stores the start-time of the window.
* `WindowedWord` stores the seconds-since-epoce as string.
src/main/java/de/juplo/kafka/wordcount/popular/PopularApplicationConfiguriation.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/popular/WindowedWord.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessorTopologyTest.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/popular/TestData.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/stats/OutputWindowedWord.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.