X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fstats%2FOutputWindowedWord.java;h=1589ea05d5d431db8a6d095482cd9ecfc40b0b10;hb=071bfe7637dd02088b0c6b22ad561b8b50677cf6;hp=83288fab5acd590f8e843912a336d1548a50e64c;hpb=a7d74628ddfe72ef2e03e9ae07244ad6e25d91b8;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/stats/OutputWindowedWord.java b/src/test/java/de/juplo/kafka/wordcount/stats/OutputWindowedWord.java
index 83288fa..1589ea0 100644
--- a/src/test/java/de/juplo/kafka/wordcount/stats/OutputWindowedWord.java
+++ b/src/test/java/de/juplo/kafka/wordcount/stats/OutputWindowedWord.java
@@ -4,12 +4,15 @@ import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+import java.time.Instant;
+
 
 @Data
 @NoArgsConstructor
 @AllArgsConstructor(staticName = "of")
 public class OutputWindowedWord
 {
-  String user;
+  Instant start;
+  Instant end;
   String word;
 }