public void advanceTime(long millis) {
    currentTime += millis;
  }
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