public Row apply()

in src/main/java/com/google/solutions/df/log/aggregations/common/MergeOutlierMap.java [25:47]

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

  public Row apply(KV<Row, Row> input) {
    return Row.withSchema(Util.outlierSchema)
        .addValues(
            input.getKey().getString("subscriber_id"),
            input.getKey().getString("dst_subnet"),
            input.getKey().getString("transaction_time"),
            input.getKey().getInt32("number_of_unique_ips"),
            input.getKey().getInt32("number_of_unique_ports"),
            input.getKey().getInt32("number_of_records"),
            input.getKey().getInt32("max_tx_bytes"),
            input.getKey().getInt32("min_tx_bytes"),
            input.getKey().getDouble("avg_tx_bytes"),
            input.getKey().getInt32("max_rx_bytes"),
            input.getKey().getInt32("min_rx_bytes"),
            input.getKey().getDouble("avg_rx_bytes"),
            input.getKey().getInt32("max_duration"),
            input.getKey().getInt32("min_duration"),
            input.getKey().getDouble("avg_duration"),
            input.getKey().getInt32("centroid_id"),
            input.getKey().getInt64("centroid_radius"),
            input.getValue().getInt64("nearest_distance_from_centroid"))
        .build();
  }