Hi, 据我所知,flink没有提供对redis connector的官方支持[1],你需要根据官方提供的接口来自定义你的redis connector,关于如何自定义connector,你可以参考文档[2]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/ [2] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sourceSinks.html Best, Xingbo 消息室 <[email protected]> 于2020年12月17日周四 上午9:33写道: > 您好: > > > 我们项目组计划使用pyflink,有幸拜读了您的博客,我想请教一下当前1.12.0版本的pyflink的sink是否支持redis > connector?感谢! > 如不支持,有何建议方式?
