X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FTestData.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FTestData.java;h=89cebaab07b3c44de4935f2dff88eca73865d1c2;hb=b1db057d3c58d20620482ff68eb210b309e615fe;hp=00ea4c4846e7811df0a9647c9f600f340507a2fd;hpb=52831df8733700f29fd2e430d7a8912c26f22c08;p=demos%2Fkafka%2Fwordcount diff --git a/src/test/java/de/juplo/kafka/wordcount/splitter/TestData.java b/src/test/java/de/juplo/kafka/wordcount/splitter/TestData.java index 00ea4c4..89cebaa 100644 --- a/src/test/java/de/juplo/kafka/wordcount/splitter/TestData.java +++ b/src/test/java/de/juplo/kafka/wordcount/splitter/TestData.java @@ -48,38 +48,38 @@ public class TestData static Stream> expectedMessages = Stream.of( KeyValue.pair( "peter", - new TestWord("peter", "Hallo")), + TestWord.of("peter", "Hallo")), KeyValue.pair( "peter", - new TestWord("peter", "Welt")), + TestWord.of("peter", "Welt")), KeyValue.pair( "klaus", - new TestWord("klaus", "Müsch")), + TestWord.of("klaus", "Müsch")), KeyValue.pair( "klaus", - new TestWord("klaus", "gäb")), + TestWord.of("klaus", "gäb")), KeyValue.pair( "klaus", - new TestWord("klaus", "s")), + TestWord.of("klaus", "s")), KeyValue.pair( "klaus", - new TestWord("klaus", "auch")), + TestWord.of("klaus", "auch")), KeyValue.pair( "peter", - new TestWord("peter", "Boäh")), + TestWord.of("peter", "Boäh")), KeyValue.pair( "peter", - new TestWord("peter", "echt")), + TestWord.of("peter", "echt")), KeyValue.pair( "peter", - new TestWord("peter", "ß")), + TestWord.of("peter", "ß")), KeyValue.pair( "peter", - new TestWord("peter", "mal")), + TestWord.of("peter", "mal")), KeyValue.pair( "peter", - new TestWord("peter", "nä")), + TestWord.of("peter", "nä")), KeyValue.pair( "peter", - new TestWord("peter", "Nümmäh"))); + TestWord.of("peter", "Nümmäh"))); }