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
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