实时计算Flink SQL中没有专门为维表设计的DDL语法,增加一行PERIOD FOR SYSTEM_TIME
的声明,即可使用标准的CREATE TABLE语法。这行声明定义了维表的变化周期,即表明该表是一张会变化的表。
示例
CREATE TABLE white_list (
id varchar,
name varchar,
age int,
PRIMARY KEY (id), -- 用作维表时,必须有声明的主键。
PERIOD FOR SYSTEM_TIME -- 定义维表的变化周期
) with (
type = 'xxx',
...
)
注意:声明一个维表的时候,必须要指名主键。维表Join的时候,on的条件必须包含所有主键的等值条件。
本文转自实时计算——数据维表概述