-package de.juplo.kafka;
-
-import java.util.HashMap;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
-
-
-public class AdderResults
-{
- private final Map<Integer, Map<String, List<AdderResult>>> results = new HashMap<>();
-
-
- public void addResults(Integer partition, String user, AdderResult result)
- {
- Map<String, List<AdderResult>> resultsByUser = this.results.get(partition);
-
- List<AdderResult> results = resultsByUser.get(user);
- if (results == null)
- {
- results = new LinkedList<>();
- resultsByUser.put(user, results);
- }
-
- results.add(result);
- }
-
- protected void addPartition(Integer partition, Map<String, List<AdderResult>> results)
- {
- this.results.put(partition, results);
- }
-
- protected Map<String, List<AdderResult>> removePartition(Integer partition)
- {
- return this.results.remove(partition);
- }
-
- public Map<Integer, Map<String, List<AdderResult>>> getState()
- {
- return results;
- }
-
- public Map<String, List<AdderResult>> getState(Integer partition)
- {
- return results.get(partition);
- }
-}