projects
/
demos
/
kafka
/
wordcount
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
query: 2.0.1 - (GREEN) Adjusted implementation to corrected expectations
[demos/kafka/wordcount]
/
src
/
test
/
java
/
de
/
juplo
/
kafka
/
wordcount
/
query
/
TestData.java
diff --git
a/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
b/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
index
1fe34d9
..
f5b8a00
100644
(file)
--- a/
src/test/java/de/juplo/kafka/wordcount/query/TestData.java
+++ b/
src/test/java/de/juplo/kafka/wordcount/query/TestData.java
@@
-2,6
+2,7
@@
package de.juplo.kafka.wordcount.query;
import de.juplo.kafka.wordcount.top10.TestEntry;
import de.juplo.kafka.wordcount.top10.TestRanking;
import de.juplo.kafka.wordcount.top10.TestEntry;
import de.juplo.kafka.wordcount.top10.TestRanking;
+import de.juplo.kafka.wordcount.top10.TestUser;
import de.juplo.kafka.wordcount.users.TestUserData;
import org.apache.kafka.streams.KeyValue;
import de.juplo.kafka.wordcount.users.TestUserData;
import org.apache.kafka.streams.KeyValue;
@@
-14,10
+15,10
@@
import static org.assertj.core.api.Assertions.assertThat;
class TestData
{
class TestData
{
- static final
String PETER = "peter"
;
- static final
String KLAUS = "klaus"
;
+ static final
TestUser PETER = TestUser.of("peter")
;
+ static final
TestUser KLAUS = TestUser.of("klaus")
;
- static final Stream<KeyValue<
String
, TestRanking>> getTop10Messages()
+ static final Stream<KeyValue<
TestUser
, TestRanking>> getTop10Messages()
{
return Stream.of(TOP10_MESSAGES);
}
{
return Stream.of(TOP10_MESSAGES);
}
@@
-29,8
+30,8
@@
class TestData
static void assertExpectedState(Function<String, UserRanking> function)
{
static void assertExpectedState(Function<String, UserRanking> function)
{
- assertRankingEqualsRankingFromLastMessage(PETER
, function.apply(PETER
));
- assertRankingEqualsRankingFromLastMessage(KLAUS
, function.apply(KLAUS
));
+ assertRankingEqualsRankingFromLastMessage(PETER
.getUser(), function.apply(PETER.getUser()
));
+ assertRankingEqualsRankingFromLastMessage(KLAUS
.getUser(), function.apply(KLAUS.getUser()
));
}
private static void assertRankingEqualsRankingFromLastMessage(String user, UserRanking rankingJson)
}
private static void assertRankingEqualsRankingFromLastMessage(String user, UserRanking rankingJson)
@@
-41,7
+42,7
@@
class TestData
private static UserRanking getLastMessageFor(String user)
{
return getTop10Messages()
private static UserRanking getLastMessageFor(String user)
{
return getTop10Messages()
- .filter(kv -> kv.key.equals(user))
+ .filter(kv -> kv.key.
getUser().
equals(user))
.map(kv -> kv.value)
.map(testRanking -> userRankingFor(user, testRanking))
.reduce(null, (left, right) -> right);
.map(kv -> kv.value)
.map(testRanking -> userRankingFor(user, testRanking))
.reduce(null, (left, right) -> right);
@@
-69,11
+70,10
@@
class TestData
{
Entry entry = new Entry();
entry.setWord(testEntry.getWord());
{
Entry entry = new Entry();
entry.setWord(testEntry.getWord());
- entry.setCount
(testEntry.getCount
());
+ entry.setCount
er(testEntry.getCounter
());
return entry;
}
return entry;
}
-
- private static KeyValue<String, TestRanking>[] TOP10_MESSAGES = new KeyValue[]
+ private static KeyValue<TestUser, TestRanking>[] TOP10_MESSAGES = new KeyValue[]
{
KeyValue.pair( // 0
PETER,
{
KeyValue.pair( // 0
PETER,
@@
-136,10
+136,10
@@
class TestData
private static KeyValue<String, TestUserData>[] USERS_MESSAGES = new KeyValue[]
{
KeyValue.pair(
private static KeyValue<String, TestUserData>[] USERS_MESSAGES = new KeyValue[]
{
KeyValue.pair(
- PETER,
- TestUserData.of(PETER, "Peter", "Pan", TestUserData.Sex.MALE)),
+ PETER
.getUser()
,
+ TestUserData.of(PETER
.getUser()
, "Peter", "Pan", TestUserData.Sex.MALE)),
KeyValue.pair(
KeyValue.pair(
- KLAUS,
- TestUserData.of(KLAUS, "Klaus", "Klüse", TestUserData.Sex.OTHER)),
+ KLAUS
.getUser()
,
+ TestUserData.of(KLAUS
.getUser()
, "Klaus", "Klüse", TestUserData.Sex.OTHER)),
};
}
};
}