projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: a7d7462) | patch
popular: 1.0.0 - Word are counted for hopping time-windows popular-1.0.0
authorKai Moritz <kai@juplo.de>
Sun, 16 Jun 2024 09:48:24 +0000 (11:48 +0200)
committerKai Moritz <kai@juplo.de>
Mon, 17 Jun 2024 19:19:51 +0000 (21:19 +0200)
commit071bfe7637dd02088b0c6b22ad561b8b50677cf6
tree1fc97e283c16040e76c97dbe349859065ead2bbatree | snapshot
parenta7d74628ddfe72ef2e03e9ae07244ad6e25d91b8commit | diff
popular: 1.0.0 - Word are counted for hopping time-windows
12 files changed:
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/UserWord.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/wordcount/popular/WindowedWord.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/wordcount/popular/Word.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/popular/WordCounter.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/popular/PopularApplicationIT.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/popular/TestMessage.java [new file with mode: 0644] blob
src/test/java/de/juplo/kafka/wordcount/stats/OutputWindowedWord.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/stats/OutputWordCounter.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.