public void processElement()

in beam-collector/src/main/java/com/google/collector/aggregation/ExtractKey.java [36:53]

• 16 lines of code
• 4 McCabe index (conditional complexity)

  public void processElement(ProcessContext ctx) {
    SecurityReport report = ctx.element();
    if (report == null) {
      return;
    }

    long checksum = 0;
    switch (report.getReportExtensionCase()) {
      case CSP_REPORT:
        checksum = computeForCsp(report.getCspReport());
        break;
      case DEPRECATION_REPORT:
        checksum = computeForDeprecation(report.getDeprecationReport());
        break;
    }

    ctx.output(KV.of(checksum, report));
  }