Flink寫入mysql

Flink寫入mysql其實也很簡單,只用繼承RichSinkFunction這個類,重寫裏面的方法就行了.具體的實現如下: /** * 把結果保存到mysql裏面 */ class MySQLSink extends RichSinkFunction[List[ItemViewCount]] with Serializable { var connection: sql.Connec

>>阅读原文<<