Source

在 SQL 中使用流表

• 目前流表定义支持 kafka、Pulsar、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 参数

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';