对redis的HSET操作，可以参考官方文档，此处不再缀述

https://bahir.apache.org/docs/flink/current/flink-streaming-redis/

SRE实战 互联网时代守护先锋，助力企业售后服务体系运筹帷幄！一键直达领取阿里云限量特价优惠。

项目中，需要使用ZADD操作，此处记录一下，如果使用redis的其他指令，应该如何使用

从官方demo中，可以看到，添加sink的代码

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

进入RedisSink查看代码，可以看到对应操作，在invoke方法中实现

FLINK redis sink的使用 随笔 第1张

其中的key, value等值，即为demo中RedisExampleMapper 对应实现方法的取值

FLINK redis sink的使用 随笔 第2张

 

 


    

        

            

                

                    

                        
                    

                    

                        

                            扫码关注我们
                        

                        

                            微信号：SRE实战
                        

                        

                            拒绝背锅 运筹帷幄