From: Kai Moritz Date: Sun, 2 Jun 2024 16:36:13 +0000 (+0200) Subject: splitter: 1.2.0 - Renamed classes for test-input/-output -- COPY X-Git-Tag: splitter-1.2.0~5 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=fa2cbce197b202b7ea32b6540c3b78fd80f4dd8e;p=demos%2Fkafka%2Fwordcount splitter: 1.2.0 - Renamed classes for test-input/-output -- COPY --- diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/TestOutputWord.java b/src/test/java/de/juplo/kafka/wordcount/counter/TestOutputWord.java new file mode 100644 index 0000000..0453671 --- /dev/null +++ b/src/test/java/de/juplo/kafka/wordcount/counter/TestOutputWord.java @@ -0,0 +1,15 @@ +package de.juplo.kafka.wordcount.counter; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + + +@Data +@NoArgsConstructor +@AllArgsConstructor(staticName = "of") +public class TestWord +{ + String user; + String word; +} diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/TestWord.java b/src/test/java/de/juplo/kafka/wordcount/counter/TestWord.java deleted file mode 100644 index 0453671..0000000 --- a/src/test/java/de/juplo/kafka/wordcount/counter/TestWord.java +++ /dev/null @@ -1,15 +0,0 @@ -package de.juplo.kafka.wordcount.counter; - -import lombok.AllArgsConstructor; -import lombok.Data; -import lombok.NoArgsConstructor; - - -@Data -@NoArgsConstructor -@AllArgsConstructor(staticName = "of") -public class TestWord -{ - String user; - String word; -} diff --git a/src/test/java/de/juplo/kafka/wordcount/recorder/TestInputRecording.java b/src/test/java/de/juplo/kafka/wordcount/recorder/TestInputRecording.java new file mode 100644 index 0000000..2d09896 --- /dev/null +++ b/src/test/java/de/juplo/kafka/wordcount/recorder/TestInputRecording.java @@ -0,0 +1,15 @@ +package de.juplo.kafka.wordcount.recorder; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + + +@Data +@NoArgsConstructor +@AllArgsConstructor(staticName = "of") +public class TestRecording +{ + String user; + String sentence; +} diff --git a/src/test/java/de/juplo/kafka/wordcount/recorder/TestRecording.java b/src/test/java/de/juplo/kafka/wordcount/recorder/TestRecording.java deleted file mode 100644 index 2d09896..0000000 --- a/src/test/java/de/juplo/kafka/wordcount/recorder/TestRecording.java +++ /dev/null @@ -1,15 +0,0 @@ -package de.juplo.kafka.wordcount.recorder; - -import lombok.AllArgsConstructor; -import lombok.Data; -import lombok.NoArgsConstructor; - - -@Data -@NoArgsConstructor -@AllArgsConstructor(staticName = "of") -public class TestRecording -{ - String user; - String sentence; -}