Re: JDBC sink for streams API

Posted by tison on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/JDBC-sink-for-streams-API-tp29356p29357.html

Hi Eduardo,

JDBCSinkFunction is a package-private class which you can make use of

by JDBCAppendTableSink. A typical statement could be

new JDBCAppendTableSink.builder()

                       . ...

                       .build()

                       .consumeDataStream(upstream);

Also JDBCUpsertTableSink and JDBCTableSourceSinkFactory are worth to give a look.

The successor of OutputFormatSinkFunction is StreamingFileSink, but it seems out of

your requirements.

Eduardo Winpenny Tejedor <[hidden email]> 于2019年8月13日周二 上午7:59写道：

Hi all,

Could someone point me to the current advised way of adding a JDBC sink? 

Online I've seen one can DataStream.writeUsingOutputFormat() however I see the OutputFormatSinkFunction is deprecated. 

I can also see a JDBCSinkFunction (or JDBCUpsertSinkFunction) but that is "package private" so I can't use it myself. JDBCAppendSinkTable makes use of it but that doesn't work with the Streams API...I tried simply copying its code into a class of my own alas the flush method in JDBCOutputFormat is also "package private"...

JDBC does not receive a lot of attention in Fabian's and Vasili's Stream Processing with Apache Flink or in the online documentation - is there a reason for this? Is it bad practice?

Regards,

Eduardo