counter: 1.2.12 - Renamed `WordCount` into `WordCounter` -- ALIGN
[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / counter / TestData.java
index c1dd45a..43e1919 100644 (file)
@@ -50,7 +50,7 @@ class TestData
                                Word.of("klaus","s"));
        }
 
-       static void assertExpectedResult(List<KeyValue<Word, WordCount>> receivedMessages)
+       static void assertExpectedResult(List<KeyValue<Word, WordCounter>> receivedMessages)
        {
                assertThat(receivedMessages).hasSize(11);
                assertThat(receivedMessages).containsSubsequence(
@@ -71,41 +71,41 @@ class TestData
                                expectedMessages[9]); // Boäh
        }
 
-       static KeyValue<Word,WordCount>[] expectedMessages = new KeyValue[]
+       static KeyValue<Word, WordCounter>[] expectedMessages = new KeyValue[]
        {
                        KeyValue.pair(
                                        Word.of("peter","Hallo"),
-                                       WordCount.of("peter","Hallo",1)),
+                                       WordCounter.of("peter","Hallo",1)),
                        KeyValue.pair(
                                        Word.of("klaus","Müsch"),
-                                       WordCount.of("klaus","Müsch",1)),
+                                       WordCounter.of("klaus","Müsch",1)),
                        KeyValue.pair(
                                        Word.of("peter","Welt"),
-                                       WordCount.of("peter","Welt",1)),
+                                       WordCounter.of("peter","Welt",1)),
                        KeyValue.pair(
                                        Word.of("klaus","Müsch"),
-                                       WordCount.of("klaus","Müsch",2)),
+                                       WordCounter.of("klaus","Müsch",2)),
                        KeyValue.pair(
                                        Word.of("klaus","s"),
-                                       WordCount.of("klaus","s",1)),
+                                       WordCounter.of("klaus","s",1)),
                        KeyValue.pair(
                                        Word.of("peter","Boäh"),
-                                       WordCount.of("peter","Boäh",1)),
+                                       WordCounter.of("peter","Boäh",1)),
                        KeyValue.pair(
                                        Word.of("peter","Welt"),
-                                       WordCount.of("peter","Welt",2)),
+                                       WordCounter.of("peter","Welt",2)),
                        KeyValue.pair(
                                        Word.of("peter","Boäh"),
-                                       WordCount.of("peter","Boäh",2)),
+                                       WordCounter.of("peter","Boäh",2)),
                        KeyValue.pair(
                                        Word.of("klaus","s"),
-                                       WordCount.of("klaus","s",2)),
+                                       WordCounter.of("klaus","s",2)),
                        KeyValue.pair(
                                        Word.of("peter","Boäh"),
-                                       WordCount.of("peter","Boäh",3)),
+                                       WordCounter.of("peter","Boäh",3)),
                        KeyValue.pair(
                                        Word.of("klaus","s"),
-                                       WordCount.of("klaus","s",3)),
+                                       WordCounter.of("klaus","s",3)),
        };
 
        static Map<String, Object> convertToMap(Properties properties)