From 9c1b63783704ee2adf031441ad13bfaba65f5969 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Tue, 25 Jun 2024 07:08:32 +0200
Subject: [PATCH] query: 2.1.2 - Refined tests (added messages, that are
filtered)
---
.../java/de/juplo/kafka/wordcount/query/TestData.java | 10 ++++++++++
1 file changed, 10 insertions(+)
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
--- 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 OTHER_CHANNEL = TestUser.of("POPULAR", "klaus");
static final Stream<KeyValue<TestUser, TestRanking>> getTop10Messages()
{
@@ -84,6 +85,10 @@ class TestData
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(
@@ -121,6 +126,11 @@ class TestData
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(
--
2.20.1