flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jark Wu <imj...@gmail.com>
Subject Re: 使用flink-sql实现mysql维表的join的ddl和dml的示列
Date Sun, 29 Sep 2019 03:41:57 GMT
Hi,

mysql 维表的 DDL 和 源表/结果表 的 DDL 是一样的。 例如下面这个 DDL 的声明,rates
在 flink sql 中既可以作为
source 也可以是 sink,也可以是维表。

CREATE TABLE rates (
    currency VARCHAR,
    rate BIGINT
) WITH (
    'connector.type' = 'jdbc', -- 使用 jdbc connector
    'connector.url' = 'jdbc:mysql://localhost:3306/flink-test', -- jdbc url
    'connector.table' = 'rates', -- 表名
    'connector.username' = 'root', -- 用户名
    'connector.password' = '123456', -- 密码
)

如果要用它作为维表的话,那么需要用到 temporal join 的语法。如:

SELECT
  o.amout, o.currency, r.rate, o.amount * r.rate
FROM
  Orders AS o
  JOIN rates FOR SYSTEM_TIME AS OF o.proctime AS r
  ON r.currency = o.currency

 关于维表 join,可以查看官方文档:
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/joins.html#join-with-a-temporal-table




On Fri, 27 Sep 2019 at 14:12, yelun <986463030@qq.com> wrote:

> Hi,各位大佬:
>
> 有没有使用flink-sql实现mysql维表的join的ddl和dml的示列的demo能够参考一下,非常感谢。
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message