class CountingInput {

  public static UnboundedCountingInput unbounded() {
    return new UnboundedCountingInput(
        new NowTimestampFn(),
        1L /* Elements per period */,
        Duration.ZERO /* Period length */,
        Optional.<Long>absent() /* Maximum number of records */,
        Optional.<Duration>absent() /* Maximum read duration */);
  }

}