Hi ,

I was looking into flink streaming api and trying to implement the solution for reading the data from jdbc database and writing them to jdbc databse again.

At the moment i can see the datastream is returning Row from the database. dataStream.getType().getGenericParameters() retuning an empty list of collection.

I am right now manually creating a database connection and getting the schema from ResultMetadata and constructing the schema for the table which is a bit heavy operation.

So is there any other way to get the schema for the table in order to create a new table and write those records in the database ?

Please let me know

Thanks
Punit

Reply via email to