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 <[email protected]> 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 <[email protected]>: > >> why do you need a connection pool? >> On 5 Jul 2016 11:41, "Harikrishnan S" <[email protected]> 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 <[email protected]> >>> 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 <[email protected]> >>>> wrote: >>>> >>>>> Hi, >>>>> >>>>> Are there any examples of implementing a jdbc sink in flink using a >>>>> connection pool ? >>>>> >>>>> Thanks >>>>> >>>> >>>> >>> >
