@VisibleForTesting
  Map<Object, ScheduledFuture> getScheduledFutures() {
    return scheduledFutures;
  }
For run loop to listen to timer firing so it can schedule the callbacks.
samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java