counter: 1.2.12 - Renamed `WordCount` into `WordCounter` -- MOVE

diff --git a/pom.xml b/pom.xml
index 5c0de9f..7289765 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -10,7 +10,7 @@
        </parent>
        <groupId>de.juplo.kafka.wordcount</groupId>
        <artifactId>counter</artifactId>
-       <version>1.2.11</version>
+       <version>1.2.12</version>
        <name>Wordcount-Counter</name>
        <description>Word-counting stream-processor of the multi-user wordcount-example</description>
        <properties>

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 (file)
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 (file)
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);
+  }
+}