ROT: Merge der korrigierten Test-Logik deserialization -> into sumup-adder
[demos/kafka/training] / 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 long offset = -1l;
19   public Map<String, AdderResult> state;
20   public Map<String, List<AdderResult>> results;
21
22   public StateDocument()
23   {
24   }
25
26   public StateDocument(Integer partition)
27   {
28     this.id = Integer.toString(partition);
29     this.state = new HashMap<>();
30     this.results = new HashMap<>();
31   }
32
33   public StateDocument(
34       Integer partition,
35       Map<String, AdderResult> state,
36       Map<String, List<AdderResult>> results,
37       long offset)
38   {
39     this.id = Integer.toString(partition);
40     this.state = state;
41     this.results = results;
42     this.offset = offset;
43   }
44 }