public static void saveMetrics()

in dbeam-core/src/main/java/com/spotify/dbeam/beam/BeamHelper.java [93:104]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  public static void saveMetrics(final Map<String, Long> metrics, final String output) {
    try {
      String metricsJson = MAPPER.writeValueAsString(metrics);
      LOGGER.info("Saving metrics: {}", metricsJson);
      saveStringOnSubPath(output, "/_METRICS.json", metricsJson);
      // for backwards compatibility
      saveStringOnSubPath(output, "/_SERVICE_METRICS.json", metricsJson);
    } catch (IOException exception) {
      // only log failures here, avoid to fail export at the end
      LOGGER.error("Failed to save metrics", exception);
    }
  }