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

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

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

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

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

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

FLINK redis sink的使用

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

FLINK redis sink的使用

 

 


 
                    
            
                

相关文章:

  • 2021-08-07
  • 2021-11-24
  • 2022-12-23
  • 2022-12-23
  • 2022-01-28
  • 2022-12-23
  • 2021-07-05
  • 2022-12-23
猜你喜欢
  • 2021-12-08
  • 2022-12-23
  • 2021-10-19
  • 2022-12-23
  • 2021-08-23
  • 2022-12-23
  • 2022-12-23
相关资源
相似解决方案