如何向JdbcIO RowMapper Java传递端输入/额外输入

import org.apache.beam.sdk.io.jdbc.JdbcIO;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.values.Row;

public class CustomRowMapper implements JdbcIO.RowMapper<CustomObject> {
    private String extraInput;

    public CustomRowMapper(String extraInput) {
        this.extraInput = extraInput;
    }

    @Override
    public CustomObject mapRow(Row row) throws Exception {
        // 使用extraInput和数据库中的行数据进行处理
        // 这里只是一个示例，具体的处理逻辑需要根据实际需求来编写
        String columnValue = row.getString("column_name");
        CustomObject customObject = new CustomObject(columnValue, extraInput);
        return customObject;
    }
}

// 在Pipeline中使用JdbcIO的示例代码
pipeline.apply(JdbcIO.<CustomObject>read()
    .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(
        "com.mysql.jdbc.Driver", "jdbc:mysql://hostname:port/database"))
    .withQuery("SELECT * FROM table")
    .withRowMapper(new CustomRowMapper("extraInput")));