public Row apply()

in src/main/java/com/google/solutions/df/log/aggregations/common/LogAggrMapElement.java [28:51]

• 21 lines of code
• 1 McCabe index (conditional complexity)

  public Row apply(Row row) {

    String dstSubnet = Util.findSubnet(row.getString("dstIP"));

    Integer duration = Util.findDuration(row.getInt64("startTime"), row.getInt64("endTime"));

    return Row.withSchema(row.getSchema())
        .addValues(
            row.getString("subscriberId"),
            row.getString("srcIP"),
            row.getString("dstIP"),
            row.getInt32("srcPort"),
            row.getInt32("dstPort"),
            row.getInt32("txBytes"),
            row.getInt32("rxBytes"),
            row.getInt64("startTime"),
            row.getInt64("endTime"),
            row.getInt32("tcpFlag"),
            row.getString("protocolName"),
            row.getInt32("protocolNumber"),
            dstSubnet,
            duration)
        .build();
  }