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删除。

猜您在找 16-Flink-Redis-Sink Flink学习（十） Sink到Redis Flink之API的使用（1）：Sink的使用 [Flink]Flink章3　Flink应用开发 --- Redis Sink Flink从socket读取数据sink到redis Flink之Sink(文件、Kafka、Redis、Es、Mysql) Flink从socket读取数据sink到redis Flink 三种Sink redis，es和jdbc Flink自定义sink到db,es,redis,kafka Flink的sink实战之一：初探