上面我們已經(jīng)使用了自定義數(shù)據(jù)源和Flink自帶的Kafka源，那么接下來就模擬著寫一個從MySQL中讀取數(shù)據(jù)的源。

示范

自定義數(shù)據(jù)源, 讀取MySql數(shù)據(jù)庫(test)表(user)數(shù)據(jù)

建表語句

相關依賴

開發(fā)步驟

• 自定義Source，繼承自定義RichSourceFunction

• 實際開放方法

• 實際運行方法

• 加載驅(qū)動

• 創(chuàng)建連接

• 創(chuàng)建PreparedStatement

• 執(zhí)行查詢

• 遍歷查詢結(jié)果,收集數(shù)據(jù)

• 使用自定義來源

• 打印結(jié)果

• 執(zhí)行任務

參考代碼