且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

数据维表概述

更新时间:2022-09-13 21:39:37

实时计算Flink SQL中没有专门为维表设计的DDL语法,增加一行PERIOD FOR SYSTEM_TIME的声明,即可使用标准的CREATE TABLE语法。这行声明定义了维表的变化周期,即表明该表是一张会变化的表。

示例


  1. CREATE TABLE white_list (
  2. id varchar,
  3. name varchar,
  4. age int,
  5. PRIMARY KEY (id), -- 用作维表时,必须有声明的主键。
  6. PERIOD FOR SYSTEM_TIME -- 定义维表的变化周期
  7. ) with (
  8. type = 'xxx',
  9. ...
  10. )

注意:声明一个维表的时候,必须要指名主键。维表Join的时候,on的条件必须包含所有主键的等值条件。


本文转自实时计算——数据维表概述