Re: 求教:pyflink的sink是否支持redis connector?

2020-12-16 文章 Dian Fu
nector-redis > 可以打包成jar包嘛,然后在pyflink里用 > > 对java不熟悉,我看这个页面里面只是对java和scala说了如何用 > > > > > > > > Best, > > MagicHuang > > > > >> -- 原始邮件 -- >> 发 件 人:"Dian Fu" >> 发送时间:2020-12-1

Re: Re: 求教:pyflink的sink是否支持redis connector?

2020-12-16 文章 magichuang
; 收 件 人:user-zh ,hepei...@qq.com > 抄 送: > 主 题:Re: 求教:pyflink的sink是否支持redis connector? > > 感谢Xingbo的回复,稍微补充一点:所有Table & SQL支持的connector都可以用在PyFlink中。 > > redis的connector没有直接在Flink的代码库里提供,这里有一个,应该也可以用:https://github.com/apache/bahir-flink/tree/master/flink-connector-red

Re: 求教:pyflink的sink是否支持redis connector?

2020-12-16 文章 Dian Fu
您好,关于JDBC connector的问题,已经回复您了,我们在另外一个thread里讨论吧。 > 在 2020年12月17日,上午10:25,肖越 <18242988...@163.com> 写道: > > 请问 可以连接oracle数据库么?自己尝试了定义connector,但报错findAndCreateTableSource failed > ,并没有找到pyflink关于oracle connector的定义示例代码 > > > > > > > > > > > > > > > > > > 在 2020-12-17 10:16:13,"Dia

Re:Re: 求教:pyflink的sink是否支持redis connector?

2020-12-16 文章 肖越
请问 可以连接oracle数据库么?自己尝试了定义connector,但报错findAndCreateTableSource failed ,并没有找到pyflink关于oracle connector的定义示例代码 在 2020-12-17 10:16:13,"Dian Fu" 写道: >感谢Xingbo的回复,稍微补充一点:所有Table & SQL支持的connector都可以用在PyFlink中。 > >redis的connector没有直接在Flink的代码库里提供,这里有一个,应该也可以用:https://github.com/apache/

Re: 求教:pyflink的sink是否支持redis connector?

2020-12-16 文章 Dian Fu
感谢Xingbo的回复,稍微补充一点:所有Table & SQL支持的connector都可以用在PyFlink中。 redis的connector没有直接在Flink的代码库里提供,这里有一个,应该也可以用:https://github.com/apache/bahir-flink/tree/master/flink-connector-redis 关于如何在PyFlink中使用connector,可以参考文档:https://ci.ap

Re: 求教:pyflink的sink是否支持redis connector?

2020-12-16 文章 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