@Override
  public int size() {
    removeExpireValues();
    return storage.size();
  }
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