public PCollection expand()

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

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

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

    return input
        .apply("AddGeoColumn", 
        		AddFields.<Row>create()
        		.field("geoCountry", Schema.FieldType.STRING)
        		.field("geoCity", Schema.FieldType.STRING)
        		.field("latitude", Schema.FieldType.DOUBLE)
        		.field("longitude", Schema.FieldType.DOUBLE))
        .setRowSchema(Util.networkLogSchemaWithGeo)
        .apply("FindGeo", ParDo.of(new IpToGeoDoFn(dbPath())));
  }