code: private ScheduledFuture<?> scheduleWriterMetricsUpdater(ScheduledThreadPoolExecutor writerMetricsUpdater,
        long scheduleInterval) {
      return writerMetricsUpdater.scheduleAtFixedRate(new WriterMetricsUpdater(), scheduleInterval, scheduleInterval,
          TimeUnit.MILLISECONDS);
    }
docs: Schedule the given {@link ScheduledThreadPoolExecutor} to run at the given interval.