public PCollection expand()

in pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/transform/RowToError.java [37:50]

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

    public PCollection<TaxiObjects.ParsingError> expand(PCollection<Row> errorRows) {
        // Create ErrorMessage events for incompatible schema (Failed records from JsonToRow)
        Schema errorMessageSchema =
                SchemaUtils.getSchemaForType(
                        errorRows.getPipeline(), TaxiObjects.ParsingError.class);

        return errorRows
                .apply(
                        "Error Message Events",
                        ParDo.of(new GenerateJsonToRowErrorMsgDoFn(errorMessageSchema)))
                .setCoder(SerializableCoder.of(Row.class))
                .setRowSchema(errorMessageSchema)
                .apply("Error Messages to Row", Convert.fromRows(TaxiObjects.ParsingError.class));
    }