Oh. So you mean if I write a custom sink for a db, I just need to create one connection in the open() method and then the invoke() method will reuse it ? Basically I need to do 35k-50k+ upserts in postgres. Can I reuse JDBCOutputFormat for this purpose ? I couldn't find a proper document describing how sinks works in flink.
On Tue, Jul 5, 2016 at 2:41 PM, Stefano Bortoli <s.bort...@gmail.com> wrote: > The connection will be managed by the splitManager, no need of using a > pool. However, if you had to, probably you should look into > establishConnection() method of the JDBCInputFormat. > > > > 2016-07-05 10:52 GMT+02:00 Flavio Pompermaier <pomperma...@okkam.it>: > >> why do you need a connection pool? >> On 5 Jul 2016 11:41, "Harikrishnan S" <hihari...@gmail.com> wrote: >> >>> Hi, >>> >>> Are there any examples of implementing a jdbc sink in flink using a >>> connection pool ? >>> >>> Thanks >>> >>> On Tue, Jul 5, 2016 at 2:00 PM, Harikrishnan S <hihari...@gmail.com> >>> wrote: >>> >>>> Hi, >>>> >>>> Are there any examples of implementing a jdbc sink in flink using a >>>> connection pool ? >>>> >>>> Thanks >>>> >>>> On Tue, Jul 5, 2016 at 1:57 PM, Harikrishnan S <hihari...@gmail.com> >>>> wrote: >>>> >>>>> Hi, >>>>> >>>>> Are there any examples of implementing a jdbc sink in flink using a >>>>> connection pool ? >>>>> >>>>> Thanks >>>>> >>>> >>>> >>> >
