Re: JDBC sink in flink

2016-07-05 Thread Harikrishnan S
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 wrote: > Hi, > > Are there any examples of implementing a jdbc sink in flink using a > connection pool ? > > Thanks > > On

Re: JDBC sink in flink

2016-07-05 Thread Harikrishnan S
t; > > 2016-07-05 10:52 GMT+02:00 Flavio Pompermaier : > >> why do you need a connection pool? >> On 5 Jul 2016 11:41, "Harikrishnan S" wrote: >> >>> Hi, >>> >>> Are there any examples of implementing a jdbc sink in flink using a >&

Re: JDBC sink in flink

2016-07-05 Thread Harikrishnan S
wrote: > why do you need a connection pool? > On 5 Jul 2016 11:41, "Harikrishnan S" wrote: > >> Hi, >> >> Are there any examples of implementing a jdbc sink in flink using a >> connection pool ? >> >> Thanks >> >> On Tue, Jul 5

Re: JDBC sink in flink

2016-07-05 Thread Harikrishnan S
the database depends on the > parallelism of the Sink, as every parallel instance creates it's own > connection. > > Regards, > Chesnay > > > On 05.07.2016 12:04, Harikrishnan S wrote: > > The basic idea was that I would create a pool of connections in the open()

Re: JDBC sink in flink

2016-07-05 Thread Harikrishnan S
> > You can however use OutputFormats in the Streaming API using the > DataStrea#writeUsingOutputFormat. > > Regards, > Chesnay > > > On 05.07.2016 12:51, Harikrishnan S wrote: > > Ah that makes send. Also what's the difference between a RichOutputFormat > and a Ri