实时计算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的条件必须包含所有主键的等值条件。
本文转自实时计算——数据维表概述