嗯，需要打成Jar包，才可以在PyFlink里用： 1）需要创建一个fat jar，把依赖都shade到jar里面。现在默认的不是fat jar，需要修改一下pom文件，可以参考Kafka里的做法 [1]。 2）关于如何使用，可用的属性有这些 [2]
[1] https://github.com/apache/flink/blob/master/flink-connectors/flink-sql-connector-kafka/pom.xml#L46 <https://github.com/apache/flink/blob/master/flink-connectors/flink-sql-connector-kafka/pom.xml#L46> [2] https://github.com/apache/bahir-flink/blob/f0b3e1e04930b79b277cfc7ebe3552db246578e9/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java <https://github.com/apache/bahir-flink/blob/f0b3e1e04930b79b277cfc7ebe3552db246578e9/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java> > 在 2020年12月17日，上午11:55，magichuang <[email protected]> 写道： > > hi, > > 想问一下您 这个 > https://github.com/apache/bahir-flink/tree/master/flink-connector-redis > 可以打包成jar包嘛，然后在pyflink里用 > > 对java不熟悉，我看这个页面里面只是对java和scala说了如何用 > > > > > > > > Best， > > MagicHuang > > > > >> ------------------ 原始邮件 ------------------ >> 发 件 人："Dian Fu" <[email protected]> >> 发送时间：2020-12-17 10:16:13 >> 收 件 人：user-zh <[email protected]>,[email protected] >> 抄 送： >> 主 题：Re: 求教：pyflink的sink是否支持redis connector? >> >> 感谢Xingbo的回复，稍微补充一点：所有Table & SQL支持的connector都可以用在PyFlink中。 >> >> redis的connector没有直接在Flink的代码库里提供，这里有一个，应该也可以用：https://github.com/apache/bahir-flink/tree/master/flink-connector-redis >> >> 关于如何在PyFlink中使用connector，可以参考文档：https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/table-api-users-guide/python_table_api_connectors.html >> >>> 在 2020年12月17日，上午9:52，Xingbo Huang 写道： >>> >>> 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 >>> >>> >>> 消息室 于2020年12月17日周四 上午9:33写道： >>> >>>> 您好： >>>> >>>> >>>> 我们项目组计划使用pyflink，有幸拜读了您的博客，我想请教一下当前1.12.0版本的pyflink的sink是否支持redis >>>> connector?感谢！ >>>> 如不支持，有何建议方式？ >> > > > >
