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?感谢!
> >>       如不支持,有何建议方式?
>




回复