1 package de.juplo.kafka;
3 import java.util.HashMap;
4 import java.util.LinkedList;
9 public class AdderResults
11 private final Map<Integer, Map<String, List<AdderResult>>> results = new HashMap<>();
14 public void addResults(Integer partition, String user, AdderResult result)
16 Map<String, List<AdderResult>> resultsByUser = this.results.get(partition);
18 if (resultsByUser == null)
20 resultsByUser = new HashMap<>();
21 results.put(partition, resultsByUser);
24 List<AdderResult> results = resultsByUser.get(user);
27 results = new LinkedList<>();
28 resultsByUser.put(user, results);
34 protected void addPartition(Integer partition, Map<String, List<AdderResult>> results)
36 this.results.put(partition, results);
39 protected Map<String, List<AdderResult>> removePartition(Integer partition)
41 return this.results.remove(partition);
44 public Map<Integer, Map<String, List<AdderResult>>> getState()
49 public Map<String, List<AdderResult>> getState(Integer partition)
51 return results.get(partition);