query: 2.1.0 - Refined input JSON (adapted to general format for stats) query-2.1.0
authorKai Moritz <kai@juplo.de>
Sat, 22 Jun 2024 17:05:45 +0000 (19:05 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 23 Jun 2024 06:53:34 +0000 (08:53 +0200)
commitd835b70fc4d49a50f42da9c21b3de1dbcd18cbaf
tree78fdf062651e10e2cb27e3283ee97477e008e168
parentb52ff02b6952dfc708c7c7d94205b5b24afd68f9
query: 2.1.0 - Refined input JSON (adapted to general format for stats)

* Adapted the app to the new type-mapping `stats` for the incomming keys.
* Refined the class `Key`, that defines the JSON for the incomming key.
** Renamed attribute `user` to `channel`.
** Added attribute `type` of type `String`.
* Refined the class `Entry`, that defines the JSON of an entry in the
  ranking, that is defined in the class `Ranking`.
** Renamed attribute `word` to `key`.
* The `QueryStreamProcessor` filters the incomming messages by the field
  `type` of the `Key`: all messages are dropped, that are not of type
  `COUNTER`.
pom.xml
src/main/java/de/juplo/kafka/wordcount/query/Entry.java
src/main/java/de/juplo/kafka/wordcount/query/Key.java
src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java
src/test/java/de/juplo/kafka/wordcount/query/QueryApplicationIT.java
src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java
src/test/java/de/juplo/kafka/wordcount/query/TestData.java
src/test/java/de/juplo/kafka/wordcount/top10/TestEntry.java
src/test/java/de/juplo/kafka/wordcount/top10/TestUser.java