projects
/
demos
/
kafka
/
wordcount
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
d9586eb
)
WIP
author
Kai Moritz
<kai@juplo.de>
Tue, 14 May 2024 22:33:34 +0000
(
00:33
+0200)
committer
Kai Moritz
<kai@juplo.de>
Tue, 14 May 2024 22:33:34 +0000
(
00:33
+0200)
src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
patch
|
blob
|
history
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
fb030e3
..
a284a5d
100644
(file)
--- a/
src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
+++ b/
src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
@@
-56,77
+56,73
@@
class TestData
{
assertThat(receivedMessages).hasSize(11);
assertThat(receivedMessages).containsSubsequence(
{
assertThat(receivedMessages).hasSize(11);
assertThat(receivedMessages).containsSubsequence(
- expectedMessages[0]); // Hallo
- assertThat(receivedMessages).containsSubsequence(
- expectedMessages[1],
- expectedMessages[3]); // Müsch
- assertThat(receivedMessages).containsSubsequence(
+ expectedMessages[0],
expectedMessages[2],
expectedMessages[2],
- expectedMessages[6]);
+ expectedMessages[5],
+ expectedMessages[6],
+ expectedMessages[7]); // peter
assertThat(receivedMessages).containsSubsequence(
assertThat(receivedMessages).containsSubsequence(
+ expectedMessages[1],
+ expectedMessages[3],
expectedMessages[4],
expectedMessages[8],
expectedMessages[4],
expectedMessages[8],
- expectedMessages[10]); // s
- assertThat(receivedMessages).containsSubsequence(
- expectedMessages[5],
- expectedMessages[7],
- expectedMessages[9]); // Boäh
+ expectedMessages[10]); // klaus
}
static KeyValue<String, Ranking>[] expectedMessages = new KeyValue[]
{
}
static KeyValue<String, Ranking>[] expectedMessages = new KeyValue[]
{
- KeyValue.pair(
+ KeyValue.pair(
// 0
"peter",
Ranking.of(
Entry.of("Hallo", 1l))),
"peter",
Ranking.of(
Entry.of("Hallo", 1l))),
- KeyValue.pair(
+ KeyValue.pair(
// 1
"klaus",
Ranking.of(
Entry.of("Müsch", 1l))),
"klaus",
Ranking.of(
Entry.of("Müsch", 1l))),
- KeyValue.pair(
+ KeyValue.pair(
// 2
"peter",
Ranking.of(
"peter",
Ranking.of(
- Entry.of("
Hallo
", 1l),
- Entry.of("
Welt
", 1l))),
- KeyValue.pair(
+ Entry.of("
Welt
", 1l),
+ Entry.of("
Hallo
", 1l))),
+ KeyValue.pair(
// 3
"klaus",
Ranking.of(
Entry.of("Müsch", 2l))),
"klaus",
Ranking.of(
Entry.of("Müsch", 2l))),
- KeyValue.pair(
+ KeyValue.pair(
// 4
"klaus",
Ranking.of(
Entry.of("Müsch", 2l),
Entry.of("s", 1l))),
"klaus",
Ranking.of(
Entry.of("Müsch", 2l),
Entry.of("s", 1l))),
- KeyValue.pair(
+ KeyValue.pair(
// 5
"peter",
Ranking.of(
"peter",
Ranking.of(
+ Entry.of("Boäh", 1l),
Entry.of("Hallo", 1l),
Entry.of("Hallo", 1l),
- Entry.of("Welt", 1l),
- Entry.of("Boäh", 1l))),
- KeyValue.pair(
+ Entry.of("Welt", 1l))),
+ KeyValue.pair( // 6
"peter",
Ranking.of(
Entry.of("Welt", 2l),
"peter",
Ranking.of(
Entry.of("Welt", 2l),
- Entry.of("
Hallo
", 1l),
- Entry.of("
Boäh
", 1l))),
- KeyValue.pair(
+ Entry.of("
Boäh
", 1l),
+ Entry.of("
Hallo
", 1l))),
+ KeyValue.pair(
// 7
"peter",
Ranking.of(
Entry.of("Welt", 2l),
Entry.of("Boäh", 2l),
Entry.of("Hallo", 1l))),
"peter",
Ranking.of(
Entry.of("Welt", 2l),
Entry.of("Boäh", 2l),
Entry.of("Hallo", 1l))),
- KeyValue.pair(
+ KeyValue.pair(
// 8
"klaus",
Ranking.of(
"klaus",
Ranking.of(
- Entry.of("
Müsch
", 2l),
- Entry.of("
s
", 2l))),
- KeyValue.pair(
+ Entry.of("
s
", 2l),
+ Entry.of("
Müsch
", 2l))),
+ KeyValue.pair(
// 9
"peter",
Ranking.of(
Entry.of("Boäh", 3l),
Entry.of("Welt", 2l),
Entry.of("Hallo", 1l))),
"peter",
Ranking.of(
Entry.of("Boäh", 3l),
Entry.of("Welt", 2l),
Entry.of("Hallo", 1l))),
- KeyValue.pair(
+ KeyValue.pair(
// 10
"klaus",
Ranking.of(
Entry.of("s", 3l),
"klaus",
Ranking.of(
Entry.of("s", 3l),