code: private synchronized void updateRecordsWrittenMeter() {
      if (this.recordsWrittenMeter.isPresent()) {
        this.recordsWrittenMeter.get().mark(recordsWritten() - this.recordsWrittenMeter.get().getCount());
      }
    }
docs: Update the {@link #recordsWrittenMeter} using the {@link DataWriter#recordsWritten()} method..