Source

在 SQL 中使用流表

  • 目前流表定义支持 kafka 和 rocketmq。

  • 在sql中使用流表：

    select * from [catalog].[database].[table]

  • 默认[catalog]：每个产品一个 catalog：slothcatalog[product]，例如 product 为 demo，catalog 为 sloth_catalog_demo

  • 默认[database]：[product]_default_db，例如 product 为 demo，默认 database 为 demo_default_db
  • 支持省略 catalog：

select * from [database].[table]

  • 支持省略 database：

select * from [table]

在 SQL 中设置 With 参数

目前原先 DDL 定义表的 With 参数都可以通过 Set 语句进行设置，具体的 With 参数可以参考 基于 DDL 方式 SQL 开发 章节。

Set语法可参考 SQL 语法 章节。

例如设置 Kafka 表 group_id

SET 'music_useraction_queue_3.connections.group.id' = 'test_group_id';
例如设置Kafka表start mode

set 'user_info.connections.startup-mode' = 'latest-offset';
例如设置Kafka表并发

set 'user_action.connector.parallelism' = '2';