Currently, there is no streaming JDBC connector. Check out this thread from last year: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/JDBC-Streaming-Connector-td10508.html
On Mon, Feb 6, 2017 at 5:00 PM, Ufuk Celebi <u...@apache.org> wrote: > I'm not sure how well this works for the streaming API. Looping in > Chesnay, who worked on this. > > On Mon, Feb 6, 2017 at 11:09 AM, Punit Tandel <punit.tan...@ericsson.com> > wrote: > > 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 >
