public void exposeWriteElapsed()

in dbeam-core/src/main/java/com/spotify/dbeam/avro/JdbcAvroMetering.java [80:91]

• 12 lines of code
• 3 McCabe index (conditional complexity)

  public void exposeWriteElapsed() {
    long elapsedMs = (System.nanoTime() - this.writeIterateStartTime) / 1000000L;
    logger.info("jdbcavroio : Read {} rows, took {} seconds", rowCount, elapsedMs / 1000.0);
    this.writeElapsedMs.inc(elapsedMs);
    if (rowCount > 0) {
      this.recordCount.inc((this.rowCount % countReportEvery));
      this.msPerMillionRows.set(1000000L * elapsedMs / rowCount);
      if (elapsedMs != 0) {
        this.rowsPerMinute.set((60 * 1000L) * rowCount / elapsedMs);
      }
    }
  }