{
@Id
public String id;
- public Map<String, Integer> statistics;
+ public long offset = -1l;
+ public Map<String, Long> statistics;
public StatisticsDocument()
{
}
- public StatisticsDocument(Integer partition, Map<String, Integer> statistics)
+ public StatisticsDocument(Integer partition)
+ {
+ this.id = Integer.toString(partition);
+ this.statistics = new HashMap<>();
+ }
+
+ public StatisticsDocument(Integer partition, Map<String, Long> statistics, long offset)
{
this.id = Integer.toString(partition);
this.statistics = statistics;
+ this.offset = offset;
}
}