From: Kai Moritz Date: Tue, 14 May 2024 19:54:20 +0000 (+0200) Subject: counter: 1.2.12 - Renamed `WordCount` into `WordCounter` -- MOVE X-Git-Tag: counter-1.2.12~1 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=b67e6b91cf7fd378fb78f0ad9e2fd47c21fbf726;p=demos%2Fkafka%2Fwordcount counter: 1.2.12 - Renamed `WordCount` into `WordCounter` -- MOVE --- diff --git a/pom.xml b/pom.xml index 5c0de9f..7289765 100644 --- a/pom.xml +++ b/pom.xml @@ -10,7 +10,7 @@ de.juplo.kafka.wordcount counter - 1.2.11 + 1.2.12 Wordcount-Counter Word-counting stream-processor of the multi-user wordcount-example diff --git a/src/main/java/de/juplo/kafka/wordcount/counter/WordCount.java b/src/main/java/de/juplo/kafka/wordcount/counter/WordCount.java deleted file mode 100644 index 958f9b7..0000000 --- a/src/main/java/de/juplo/kafka/wordcount/counter/WordCount.java +++ /dev/null @@ -1,21 +0,0 @@ -package de.juplo.kafka.wordcount.counter; - -import lombok.AllArgsConstructor; -import lombok.Data; -import lombok.NoArgsConstructor; - - -@Data -@NoArgsConstructor -@AllArgsConstructor(staticName = "of") -public class WordCount -{ - String user; - String word; - long count; - - public static WordCount of(Word word, long count) - { - return new WordCount(word.getUser(), word.getWord(), count); - } -} diff --git a/src/main/java/de/juplo/kafka/wordcount/counter/WordCounter.java b/src/main/java/de/juplo/kafka/wordcount/counter/WordCounter.java new file mode 100644 index 0000000..958f9b7 --- /dev/null +++ b/src/main/java/de/juplo/kafka/wordcount/counter/WordCounter.java @@ -0,0 +1,21 @@ +package de.juplo.kafka.wordcount.counter; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + + +@Data +@NoArgsConstructor +@AllArgsConstructor(staticName = "of") +public class WordCount +{ + String user; + String word; + long count; + + public static WordCount of(Word word, long count) + { + return new WordCount(word.getUser(), word.getWord(), count); + } +}