X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FTestData.java;h=fb030e39479145e561e834b2c62d8320401d24c9;hb=87f82fe35276666d298bc5100f0810b6aa6ce2d4;hp=fd18d2645bfceda439953e1556fa1ec1d651490f;hpb=5ece428364118199f8cf89a0521f38aeefbcbf0a;p=demos%2Fkafka%2Fwordcount diff --git a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java index fd18d26..fb030e3 100644 --- a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java +++ b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java @@ -77,7 +77,60 @@ class TestData { KeyValue.pair( "peter", - Ranking.of("peter","Hallo",1)), + Ranking.of( + Entry.of("Hallo", 1l))), + KeyValue.pair( + "klaus", + Ranking.of( + Entry.of("Müsch", 1l))), + KeyValue.pair( + "peter", + Ranking.of( + Entry.of("Hallo", 1l), + Entry.of("Welt", 1l))), + KeyValue.pair( + "klaus", + Ranking.of( + Entry.of("Müsch", 2l))), + KeyValue.pair( + "klaus", + Ranking.of( + Entry.of("Müsch", 2l), + Entry.of("s", 1l))), + KeyValue.pair( + "peter", + Ranking.of( + Entry.of("Hallo", 1l), + Entry.of("Welt", 1l), + Entry.of("Boäh", 1l))), + KeyValue.pair( + "peter", + Ranking.of( + Entry.of("Welt", 2l), + Entry.of("Hallo", 1l), + Entry.of("Boäh", 1l))), + KeyValue.pair( + "peter", + Ranking.of( + Entry.of("Welt", 2l), + Entry.of("Boäh", 2l), + Entry.of("Hallo", 1l))), + KeyValue.pair( + "klaus", + Ranking.of( + Entry.of("Müsch", 2l), + Entry.of("s", 2l))), + KeyValue.pair( + "peter", + Ranking.of( + Entry.of("Boäh", 3l), + Entry.of("Welt", 2l), + Entry.of("Hallo", 1l))), + KeyValue.pair( + "klaus", + Ranking.of( + Entry.of("s", 3l), + Entry.of("Müsch", 2l))), }; static Map convertToMap(Properties properties)