public void advanceTime(Duration duration) {
    currentTime += duration.toMillis();
  }
An implementation of {@link Clock} that allows to advance the time by an arbitrary duration.
Used for testing.
samza-core/src/main/java/org/apache/samza/testUtils/TestClock.java