Записать данные, доступные в файле GCS, в облако SQL, используя поток данных JdbcIO API

Question

Как записать данные, доступные в файле GCS, т.е. "gs://***/sampleBigtable.csv" в СУБД СУБД. Не могли бы вы поделиться примером.

pipeline
        .apply(TextIO.read().from("gs://***/sampleBigtable.csv"))
        .apply(JdbcIO.<String>write().withDataSourceConfiguration(
            DataSourceConfiguration.create("org.postgresql.Driver","jdbc:postgresql://***:5432/test")
                .withUsername("**")
                .withPassword("password10"))
                .withStatement("insert into person values(?,?)")
                    .withPreparedStatementSetter((element, query) -> {
                        query.setInt(1, 1);
                        query.setString(2, "Hello");
                    })
        );