private void removeExpireValues() {
    storage.headMap(getUpdatingTime() - windowMs).clear();
  }
Remove the values that are earlier than current window
samza-api/src/main/java/org/apache/samza/metrics/SlidingTimeWindowReservoir.java