原文：Flink從socket讀取數據sink到redis
通過nc命令模擬發送數據： 控制台打印的信息： 在Redis中查看socket發送過來的數據： ...
2020-03-25 21:49 1 1345 推薦指數：
相關推薦
對redis的HSET操作，可以參考官方文檔，此處不再綴述 https://bahir.apache.org/docs/flink/current/flink-streaming-redis/ 項目中，需要使用ZADD操作，此處記錄一下，如果使用redis的其他指令，應該如何使用 從官方 ...
Kafka Flink 讀取 Kafka 中的數據，清洗后寫入 ODS 層（Kafka），同時 ...
戳更多文章： 1-Flink入門 2-本地環境搭建&構建第一個Flink應用 3-DataSet API 4-DataSteam API 5-集群部署 6-分布式緩存 7-重啟策略 8-Flink中的窗口 9-Flink中的Time Flink時間戳和水印 ...
添加依賴 編寫代碼 ...
自定義flink的RedisSource，實現從redis中讀取數據，這里借鑒了flink-connector-redis_2.11的實現邏輯，實現對redis讀取的邏輯封裝，flink-connector-redis_2.11的使用和介紹可參考之前的博客，項目中需要引入 ...
Flink提供了專門操作redis的Redis Sink 依賴 類 Redis Sink 提供用於向Redis發送數據的接口的類。接收器可以使用三種不同的方法與不同類型的Redis環境進行通信： 類 場景 備注 ...
提醒: 數據格式 ##########保存至文件############## 1、處理主類 ##########保存至Es############## 1、依賴 2、處理主類 ##########保存 ...