您好,关于JDBC connector的问题,已经回复您了,我们在另外一个thread里讨论吧。

> 在 2020年12月17日,上午10:25,肖越 <[email protected]> 写道:
> 
> 请问 可以连接oracle数据库么?自己尝试了定义connector,但报错findAndCreateTableSource failed 
> ,并没有找到pyflink关于oracle connector的定义示例代码
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 在 2020-12-17 10:16:13,"Dian Fu" <[email protected]> 写道:
>> 感谢Xingbo的回复,稍微补充一点:所有Table & SQL支持的connector都可以用在PyFlink中。
>> 
>> redis的connector没有直接在Flink的代码库里提供,这里有一个,应该也可以用:https://github.com/apache/bahir-flink/tree/master/flink-connector-redis
>>  <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 <[email protected]> 写道:
>>> 
>>> 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写道:
>>> 
>>>> 您好:
>>>> 
>>>> &nbsp; &nbsp; &nbsp;
>>>> 我们项目组计划使用pyflink,有幸拜读了您的博客,我想请教一下当前1.12.0版本的pyflink的sink是否支持redis
>>>> connector?感谢!
>>>> &nbsp; &nbsp; &nbsp; 如不支持,有何建议方式?
>> 

回复