Hi, If you are ok to use Hive via JDBC, you can use JdbcIO and see the example in the javadoc:
https://github.com/apache/beam/blob/master/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java#L82 <https://github.com/apache/beam/blob/master/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java#L82> Regards JB > Le 11 févr. 2020 à 07:03, Gershi, Noam <noam.ger...@citi.com> a écrit : > > Hi, > > I am searching for a detailed example how to use Apache Beam with Hive and/or > Hcatalog? > Creating tables, inserting data and fetching it… > > > Noam Gershi Software Developer > ICG Technology – TLV Lab > T: +972 (3) 7405718 > > <image002.png>