top10: 1.3.0 - Refined input JSON to match the new general stats-format top10-1.3.0
authorKai Moritz <kai@juplo.de>
Sat, 22 Jun 2024 14:09:46 +0000 (16:09 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 22 Jun 2024 16:11:49 +0000 (18:11 +0200)
commit5030aed19804a0c48f1968208e176657bdd147de
tree0942c1e9a2700a209c86640ae7810daf176f2623
parent066ac7e345947764b28084b9961b1633264d63d0
top10: 1.3.0 - Refined input JSON to match the new general stats-format

* Adapted the configuration to the changed type-mapping for the key.
* Refined the class `Key`, that defines the JSON for the input key.
** Added attribute `type` with value of type `enum StatsType`.
** Renamed attribute `user` to `channel`.
** Renamed attribute `word` to `key`.
* Refined the class `Entry`, that defines the JSON for the input value.
** Renamed attribute `word` to `key`.
* Adapted test-classes and -cases accordingly.
14 files changed:
pom.xml
src/main/java/de/juplo/kafka/wordcount/top10/Entry.java
src/main/java/de/juplo/kafka/wordcount/top10/Key.java
src/main/java/de/juplo/kafka/wordcount/top10/Ranking.java
src/main/java/de/juplo/kafka/wordcount/top10/StatsType.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/wordcount/top10/Top10ApplicationConfiguration.java
src/main/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessor.java
src/test/java/de/juplo/kafka/wordcount/counter/TestCounter.java
src/test/java/de/juplo/kafka/wordcount/counter/TestWord.java
src/test/java/de/juplo/kafka/wordcount/query/TestEntry.java
src/test/java/de/juplo/kafka/wordcount/top10/RankingTest.java
src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
src/test/java/de/juplo/kafka/wordcount/top10/Top10ApplicationIT.java
src/test/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessorTopologyTest.java