Hi You have the setPrepareStatement() method where you define the target tables. However, it’s in the same database (datasource) per pipeline.
You can define several datasources and use a different datasource in each JdbcIO write. Meaning that you can divide in sub pipelines. Regards JB > Le 29 févr. 2020 à 17:52, Vasu Gupta <dev.vasugu...@gmail.com> a écrit : > > Hey folks, > > Can we use JdbcIO for writing data to multiple Schemas(For Postgres Database) > dynamically using Apache beam Java Framework? Currently, I can't find any > property that I could set to JdbcIO transform for providing schema or maybe I > am missing something. > > Thanks
