Mysql 维表DDL语法

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Mysql 维表DDL语法

yelun
Hi

        我想做一个Flink SQL 中DataStream流的数据与Mysql维表的Join功能,请问当前flink-1.9的snapshot版本支持连接Mysql数据库的DDL功能,并且可以跟DataStream流做join,支持MySQL维表的实时更新。

谢谢。
Reply | Threaded
Open this post in threaded view
|

Re: Mysql 维表DDL语法

Caizhi Weng
Hi yelun

    现在的 master 分支已经支持 JDBCLookupFunction[1],另外 JDBCTableSourceSinkFactory 的
PR[2] 正在 review 中。JDBCLookupFunction 应该能满足你的需求。

[1] https://github.com/apache/flink/pull/8923
[2] https://github.com/apache/flink/pull/9029

yelun <[hidden email]> 于2019年7月8日周一 下午3:17写道:

> Hi
>
>         我想做一个Flink SQL
> 中DataStream流的数据与Mysql维表的Join功能,请问当前flink-1.9的snapshot版本支持连接Mysql数据库的DDL功能,并且可以跟DataStream流做join,支持MySQL维表的实时更新。
>
> 谢谢。