You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Roc Marshal <fl...@126.com> on 2021/07/08 02:42:34 UTC

Flink SQL MYSQL schema 特性问题

Hi, 
   请问目前的 Flink SQL 在创建source表的时候支持自动拉取所有的表列信息并解析吗？


   谢谢。


Best, Roc.

Re: Flink SQL MYSQL schema 特性问题

Posted by Terry Wang <zj...@gmail.com>.

Hi~
	你需要的应该是flink sql里提供的catalog功能 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/jdbc/#postgres-database-as-a-catalog
 	目前PostgresCatalog实现了jdbc catalog，MysqlCatalog没有支持，有一些资料可以参考实现:  https://vendanner.github.io/2020/11/25/Flink-SQL-%E4%B9%8B-MySQL-Catalog/



Best,
Terry Wang



> 2021年7月8日 上午10:42，Roc Marshal <fl...@126.com> 写道：
> 
> Hi, 
>   请问目前的 Flink SQL 在创建source表的时候支持自动拉取所有的表列信息并解析吗？
> 
> 
>   谢谢。
> 
> 
> Best, Roc.