Re: Save the flink KeyStream to oracle db table

2017-06-14 Thread Fabian Hueske
Hi Meera, You can emit a DataStream using a SinkFunction. Flink provides SinkFunctions for a couple of systems but AFAIK, none to write data to a relational database, i.e., a JdbcSinkFunction [1]. I think the right way to do this is to implement a JdbcSinkFunction. We have a JdbcOutputFormat whic

Save the flink KeyStream to oracle db table

2017-06-08 Thread Meera nyjen
Hi, I have started using flink recently in my application. i am trying to save a transformed data stream to an oracle db. I was currently using writeascsv(filepath), to save the data to a file. When i say data, it is the kafka message. This kafka message is a file name. I used kafka consumer to re