public void incrementRecordCount()

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

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

  public void incrementRecordCount() {
    this.rowCount++;
    if ((this.rowCount % countReportEvery) == 0) {
      this.recordCount.inc(countReportEvery);
      final long elapsedNano = System.nanoTime() - this.writeIterateStartTime;
      final long msPerMillionRows = elapsedNano / rowCount;
      final long rowsPerMinute = (60 * 1000000000L) * rowCount / elapsedNano;
      this.msPerMillionRows.set(msPerMillionRows);
      this.rowsPerMinute.set(rowsPerMinute);
      if ((this.rowCount % logEvery) == 0) {
        logger.info(
            String.format(
                "jdbcavroio : Fetched # %08d rows at %08d rows per minute and %08d ms per M rows",
                rowCount, rowsPerMinute, msPerMillionRows));
      }
    }
  }