package de.juplo.kafka.wordcount.counter;
+import lombok.AccessLevel;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
-@AllArgsConstructor(staticName = "of")
-public class WordCount
+@AllArgsConstructor(access = AccessLevel.PRIVATE)
+public class WordCounter
{
String user;
String word;
- long count;
+ long counter;
- public static WordCount of(Word word, long count)
+ public static WordCounter of(Word word, long counter)
{
- return new WordCount(word.getUser(), word.getWord(), count);
+ return new WordCounter(word.getUser(), word.getWord(), counter);
}
}