Vereinfachte Version der auf Spring Kafka basierenden Implementierung
[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 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 }