public PCollection expand()

in src/main/java/com/google/solutions/df/log/aggregations/common/PredictTransform.java [54:67]

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

  public PCollection<Row> expand(PCollection<Row> input) {

    return input
        .apply(
            "Distance From Nearest Centroid",
            ParDo.of(new FindEuclideanDistance(centroidFeatureVector()))
                .withSideInputs(centroidFeatureVector()))
        .setRowSchema(Util.outlierSchema)
        .apply(
            "Find Outliers(Z-Score)",
            ParDo.of(new CheckOutlierThreshold(centroidFeatureVector()))
                .withSideInputs(centroidFeatureVector()))
        .setRowSchema(Util.outlierSchema);
  }