public CentroidVector apply()

in src/main/java/com/google/solutions/df/log/aggregations/common/ClusterDataMapElement.java [27:48]

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

  public CentroidVector apply(SchemaAndRecord input) {

    ImmutableList<Double> featureVector =
        ImmutableList.of(
            Double.parseDouble(input.getRecord().get("number_of_records").toString()),
            Double.parseDouble(input.getRecord().get("max_tx_bytes").toString()),
            Double.parseDouble(input.getRecord().get("min_tx_bytes").toString()),
            Double.parseDouble(input.getRecord().get("avg_tx_bytes").toString()),
            Double.parseDouble(input.getRecord().get("max_rx_bytes").toString()),
            Double.parseDouble(input.getRecord().get("min_rx_bytes").toString()),
            Double.parseDouble(input.getRecord().get("avg_rx_bytes").toString()),
            Double.parseDouble(input.getRecord().get("max_duration").toString()),
            Double.parseDouble(input.getRecord().get("min_duration").toString()),
            Double.parseDouble(input.getRecord().get("avg_duration").toString()));

    return CentroidVector.newBuilder()
        .setCentroidId(Integer.parseInt(input.getRecord().get("centroid_id").toString()))
        .setNormalizedDistance(
            Double.parseDouble(input.getRecord().get("normalized_dest").toString()))
        .setFeatureVectors(featureVector)
        .build();
  }