+ static final TestStats PETER = TestStats.of(StatsType.COUNTER.name(), "peter");
+ static final TestStats KLAUS = TestStats.of(StatsType.COUNTER.name(), "klaus");
+
+ static final Stream<KeyValue<TestWord, TestCounter>> getInputMessages()
+ {
+ return Stream.of(INPUT_MESSAGES);
+ }
+
+ private static final KeyValue<TestWord, TestCounter>[] INPUT_MESSAGES = new KeyValue[]