FLINK redis sink的使用

本文轉載自查看原文 2019-04-10 10:36 1461 flink/ redis/ ZADD

對redis的HSET操作，可以參考官方文檔，此處不再綴述

項目中，需要使用ZADD操作，此處記錄一下，如果使用redis的其他指令，應該如何使用

從官方demo中，可以看到，添加sink的代碼

stream.addSink(new RedisSink<Tuple2<String, String>>(conf, new RedisExampleMapper());

進入RedisSink查看代碼，可以看到對應操作，在invoke方法中實現

其中的key, value等值，即為demo中RedisExampleMapper 對應實現方法的取值

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 Flink學習（十） Sink到Redis Flink之API的使用（1）：Sink的使用 Flink從socket讀取數據sink到redis Flink 三種Sink redis，es和jdbc Flink自定義sink到db,es,redis,kafka Flink Sink定制開發 6、Flink的常用Sink Flink自定義Sink Flink學習（十一） Sink到Elasticsearch Flink流處理-Sink之HBase