??????????flink-sql????mysql??????join??ddl??dml??????

[????????]

????sql ddl????????o.proctime????


 
---????????---
??????: "Jark Wu"<imj...@gmail.com&gt;
????????: 2019??9??29??(??????) ????11:42
??????: "user-zh"<user-zh@flink.apache.org&gt;;
????: Re: ????flink-sql????mysql??????join??ddl??dml??????


Hi,

mysql ?????? DDL ?? ????/?????? ?? DDL ?????????? ???????????? DDL 
????????rates ?? flink sql ????????????
source ???????? sink????????????????

CREATE TABLE rates (
&nbsp;&nbsp;&nbsp; currency VARCHAR,
&nbsp;&nbsp;&nbsp; rate BIGINT
) WITH (
&nbsp;&nbsp;&nbsp; 'connector.type' = 'jdbc', -- ???? jdbc connector
&nbsp;&nbsp;&nbsp; 'connector.url' = 'jdbc:mysql://localhost:3306/flink-test', 
-- jdbc url
&nbsp;&nbsp;&nbsp; 'connector.table' = 'rates', -- ????
&nbsp;&nbsp;&nbsp; 'connector.username' = 'root', -- ??????
&nbsp;&nbsp;&nbsp; 'connector.password' = '123456', -- ????
)

???????????????????????????????????? temporal join ????????????

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

&nbsp;???????? 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 <986463...@qq.com&gt; wrote:

&gt; Hi????????????
&gt;
&gt; 
??????????flink-sql????mysql??????join??ddl??dml????????demo????????????????????????