文件名称：flink-redis-sink:使用TableSQL API帮助沉入Redis
文件大小：35KB
文件格式：ZIP
更新时间：2024-06-15 08:39:56
Java
该项目用于使用表或sql api将数据写入flink流应用程序中的redis。 之前，我看到了项目，该项目具有一个模块来帮助使用flink写入redis。 但是，它可以工作，但与我的愿望并不完全匹配。 当我想将行/表沉入redis中时： Firstly,i'd like to choose one or more field as the redis key, Secondly, i'd like to take the row as a map or json string as the value. Thirdly, watermark needs to be supported too. 但是，如果不更改源代码，它看起来并不容易。 我想写我自己的redis-sink。 当您查看此项目时，有一些技巧需要记住： 该项目仅支持REDIS CLUSTER模式。 该项目使用redi
【文件预览】：
flink-redis-sink-master
----src()
--------test()
--------main()
----redis-sink.iml(80B)
----LICENSE(11KB)
----README.md(1KB)
----pom.xml(8KB)
----.gitignore(12B)