PostgresAlbumRead.java

PCollection<HashMap<String, Object>> rows = pipeline.apply(
  "Read Albums from PG",
  JdbcIO.<HashMap<String, Object>>read()
    .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(pgDataSource))
    .withCoder(TableRowCoder.of())
    // Map ResultSet row to a HashMap
    .withRowMapper(new RowMapper<HashMap<String, Object>>() {
      @Override
      public HashMap<String, Object> mapRow(ResultSet resultSet) throws Exception {
        return TableRowMapper.asMap(resultSet, tableName, pkName);
      }
    })
    .withQuery("select * from public.\"Album\""));