private static ScheduledThreadPoolExecutor buildWriterMetricsUpdater() {
    return new ScheduledThreadPoolExecutor(1,
        ExecutorsUtils.newThreadFactory(Optional.of(log), Optional.of("WriterMetricsUpdater-%d")));
  }
private static ScheduledThreadPoolExecutor buildWriterMetricsUpdater ( ) { return new ScheduledThreadPoolExecutor ( 1 , ExecutorsUtils . newThreadFactory ( Optional . of ( log ) , Optional . of ( "WriterMetricsUpdater-%d" ) ) ) ; }
Build a {@link ScheduledThreadPoolExecutor} that updates record-level and byte-level metrics.