flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Felix Dreissig <...@f30.me>
Subject Re: Guys, How to use JDBC connection in Flink using Scala
Date Sat, 24 Sep 2016 17:22:03 GMT
Hi Ram,

On 24 Sep 2016, at 18:32, ram kumar <ramkumar09951@gmail.com> wrote:
> To connect redshift ( for staging and production database ) I need to setup JDBC connection
in Flink Scala.
> 
>  
> 
> Kafka (Source) ------------>  Flink  (JDBC)  -----------> AWS ( S3 and Redshift)
Target.
> 
>  
> Could you please suggest me the best approach for this use case.

If you get your stream from somewhere else (i.e. Kafka) and the database (i.e. Redshift) is
your target only, forget what I told in my previous mail.
You could just write a DataSink that uses JDBC and connects to your target, but I don’t
have any tips or even sample code for that.

Regards,
Felix
Mime
View raw message