juplo.de Git - demos/kafka/training/blob - src/main/java/de/juplo/kafka/StateDocument.java

   1 package de.juplo.kafka;
   2
   3 import lombok.ToString;
   4 import org.springframework.data.annotation.Id;
   5 import org.springframework.data.mongodb.core.mapping.Document;
   6
   7 import java.util.HashMap;
   8 import java.util.List;
   9 import java.util.Map;
  10
  11
  12 @Document(collection = "state")
  13 @ToString
  14 public class StateDocument
  15 {
  16   @Id
  17   public String id;
  18   public Map<String, AdderResult> state;
  19   public Map<String, List<AdderResult>> results;
  20
  21   public StateDocument()
  22   {
  23   }
  24
  25   public StateDocument(Integer partition)
  26   {
  27     this.id = Integer.toString(partition);
  28     this.state = new HashMap<>();
  29     this.results = new HashMap<>();
  30   }
  31
  32   public StateDocument(
  33       Integer partition,
  34       Map<String, AdderResult> state,
  35       Map<String, List<AdderResult>> results)
  36   {
  37     this.id = Integer.toString(partition);
  38     this.state = state;
  39     this.results = results;
  40   }
  41 }