Hi, Using the DataStream API I could create a Custom Sink like classRichMySqlSink extends RichSinkFunction<String> and define my desire behavior in inserting data into mysql table. But using the DataSet API I just can find the output method for sinking data and it accept just OutputFormat data type. In addition I don't want to use the Built-in Flink JDBCOutputFormat.
So is there any way to create my own Sink Class for inserting data into mysql?
