@Override
  public void update(long value) {
    if (count.incrementAndGet() % REMOVE_IN_UPDATE_THRESHOLD == 0) {
      removeExpireValues();
    }
    storage.put(getUpdatingTime(), value);
  }
Construct the SlidingTimeWindowReservoir with window size

@param windowMs the size of the window. unit is millisecond.
samza-api/src/main/java/org/apache/samza/metrics/SlidingTimeWindowReservoir.java