private static void addCalculatedMetrics()

in dbeam-core/src/main/java/com/spotify/dbeam/beam/MetricsHelper.java [87:98]

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

  private static void addCalculatedMetrics(
      final Map<String, Long> counters, final Map<String, Long> ret) {
    // calculate and add KBps
    final Long writeElapsedMs = counters.get("writeElapsedMs");
    final Long kbps;
    if (writeElapsedMs != null && writeElapsedMs > 0) {
      kbps = counters.get("bytesWritten") / writeElapsedMs;
    } else {
      kbps = -1L;
    }
    ret.put("KbWritePerSec", kbps);
  }