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.1.2 - Refined tests (added messages, that are filtered)
[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
44162a0
..
7c71312
100644
(file)
--- a/
src/test/java/de/juplo/kafka/wordcount/query/TestData.java
+++ b/
src/test/java/de/juplo/kafka/wordcount/query/TestData.java
@@
-18,6
+18,7
@@
class TestData
{
static final TestUser PETER = TestUser.of(STATS_TYPE, "peter");
static final TestUser KLAUS = TestUser.of(STATS_TYPE, "klaus");
{
static final TestUser PETER = TestUser.of(STATS_TYPE, "peter");
static final TestUser KLAUS = TestUser.of(STATS_TYPE, "klaus");
+ static final TestUser OTHER_CHANNEL = TestUser.of("POPULAR", "klaus");
static final Stream<KeyValue<TestUser, TestRanking>> getTop10Messages()
{
static final Stream<KeyValue<TestUser, TestRanking>> getTop10Messages()
{
@@
-84,6
+85,10
@@
class TestData
KLAUS,
TestRanking.of(
TestEntry.of("Müsch", 1l))),
KLAUS,
TestRanking.of(
TestEntry.of("Müsch", 1l))),
+ KeyValue.pair( // 1
+ OTHER_CHANNEL,
+ TestRanking.of(
+ TestEntry.of("Müsch", 1l))),
KeyValue.pair( // 2
PETER,
TestRanking.of(
KeyValue.pair( // 2
PETER,
TestRanking.of(
@@
-121,6
+126,11
@@
class TestData
TestRanking.of(
TestEntry.of("Müsch", 2l),
TestEntry.of("s", 2l))),
TestRanking.of(
TestEntry.of("Müsch", 2l),
TestEntry.of("s", 2l))),
+ KeyValue.pair( // 8
+ OTHER_CHANNEL,
+ TestRanking.of(
+ TestEntry.of("Müsch", 2l),
+ TestEntry.of("s", 2l))),
KeyValue.pair( // 9
PETER,
TestRanking.of(
KeyValue.pair( // 9
PETER,
TestRanking.of(