一、寫入mysql 1.pom.xml 2.在flink中沒有現成的用來寫入MySQL的sink，但是flink提供了一個類，JDBCOutputFormat，通過這個類，如果你提供了jdbc的driver，則可以當做sink使用。 JDBCOutputFormat其實是 ...

Flink 讀寫Kafka 在Flink中，我們分別用Source Connectors代表連接數據源的連接器，用Sink Connector代表連接數據輸出的連接器。下面我們介紹一下Flink中用於讀寫kafka的source & sink connector。 Apache ...

iceberg 0.11 發布的時候稍微嘗試了一下，發現實際並沒有說的那么厲害，很多功能其實還在開發中(比如： upsert) 貼段之前寫的 flink sql： 注： 貌似沒有 hive catalog，只能放在 hadoop 上面，不支持 upsert iceberg master ...

項目pom文件 實現flink寫入redis 實現wordcount功能，並將結果實時寫入redis，這里使用了第三方依賴flink-connector-redis_2.11，該依賴提供了RedisSink可以直接使用，具體代碼如下： 代碼 首先定義數據源處理實現類 ...

最近因為疫情的原因，偷了好長時間的懶，現在終於開始繼續看Flink 的SQL 了 ———————————————— 電腦上的Flink 項目早就升級到了 1.10了，最近還在看官網新的文檔，趁着周末，體驗一下新版本的SQL API（踩一下坑）。 直接從之前的 雲邪大佬的Flink ...

...

Flink的kafka connector文檔 https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/connectors/kafka.html Flink寫入kafka時候需要實現序列化和反序列化 ...

源碼結構 RedisSink RedisSink類繼承了RichSinkFunction類，擴展了其中的open、invoke、close方法。open方法在sink打開時執行一次，在Re ...