Hi!
你想要将主表和两张维表进行连续的 event time temporal join 吗?
第一个 SQL 语句是不是不完整,只有一个 join on 却有两张表。
第二个 SQL 语句中,首先定义 view 应该通过 create view 语句,其次 event time temporal join
应该使用左表的 event time。你的语句中,第一个 join 使用的是 FOR SYSTEM_TIME AS OF
job.lastUpdateTime 这是正确的,但第二个 join 使用的是 FOR SYSTEM_TIME AS OF
Hi!
你看的是阿里云 Blink 的文档。Blink 是阿里原来基于 Flink 1.5 开发的产品,所以一些语法与现在的 Flink
有些不同。period for system_time 是以前 blink 定义维表的语法,现在不需要写了。另外 datagen
确实不能作为维表的数据来源,可以尝试用文件作为维表来源,比如 csv 文件。
目前 Blink 的大部分代码已贡献回 Flink(Flink 1.14 默认 planner 就是原来的 Blink planner),建议直接看
Flink 官网的文档学习[1]。
如果想要了解商业化的内容,应该看阿里云 Flink
flink??join??join??https://help.aliyun.com/document_detail/62506.html??flink
sql?? ddl??
create table phoneNumber( name VARCHAR, phoneNumber bigint, primary key(name),
PERIOD FOR SYSTEM_TIME )with(