Lindorm维表

什么是云原生多模数据库Lindorm

Lindorm是面向物联网、互联网、车联网等设计和优化的云原生多模超融合数据库，是日志、监控、账单、广告、社交、出行、风控等场景首选数据库，也是为阿里巴巴核心业务提供支撑的数据库之一。详情请参见什么是云原生多模数据库Lindorm。

前提条件

• 已经创建了Lindorm宽表引擎以及数据表，详情请参见创建实例。
• Lindorm集群与Flink全托管集群处于网络连通的环境下，例如在同一个VPC下。

使用限制

仅Flink计算引擎VVR 4.0.8及以上版本支持Lindorm。

注意事项

声明维表时，必须要指名主键，维表JOIN时，ON的条件必须包含所有主键的等值条件。

DDL定义

CREATE TABLE white_list (
 id varchar,
 name varchar,
 age int,
 PRIMARY KEY (id) NOT ENFORCED
) WITH (
 'connector' = 'lindorm', 
 'seedserver' = '<yourSeedServer>',
 'namespace' = '<yourNamespace>',
 'username' = '<yourUsername>',
 'password' = '<yourPassword>',
 'tableName' = '<yourTableName>',
 'columnFamily' = '<yourColumnFamily>'
);

WITH参数

Cache参数

类型映射

代码示例

CREATE TEMPORARY TABLE lindorm_source(
 id INT,
 proc_time AS PROCTIME()
) WITH (
 'connector' = 'datagen',
 'number-of-rows' = '10',
 'fields.id.kind' = 'sequence',
 'fields.id.start' = '0',
 'fields.id.end' = '9'
);

CREATE TEMPORARY TABLE lindorm_hbase_dim(
 `id` INT,
 `name` VARCHAR,
 `birth` VARCHAR,
 PRIMARY KEY (id) NOT ENFORCED
) WITH (
 'connector'='lindorm',
 'tablename'='${lindorm_dim_table}',
 'seedserver'='${lindorm_seed_server}',
 'namespace'='default',
 'username'='${lindorm_username}',
 'password'='${lindorm_username}'
);

CREATE TEMPORARY TABLE lindorm_hbase_sink(
 `id` INT,
 `name` VARCHAR,
 `birth` VARCHAR,
 PRIMARY KEY (id) NOT ENFORCED
) WITH (
 'connector'='lindorm',
 'tablename'='${lindorm_sink_table}',
 'seedserver'='${lindorm_seed_server}',
 'namespace'='default',
 'username'='${lindorm_username}',
 'password'='${lindorm_username}'
);

INSERT INTO lindorm_hbase_sink
SELECT lindorm_source.id as id, lindorm_hbase_dim.name as name, lindorm_hbase_dim.birth as birth
FROM lindorm_source JOIN lindorm_hbase_dim FOR SYSTEM_TIME AS OF PROCTIME() ON lindorm_source.id = lindorm_hbase_dim.id;