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

  1. SET 'music_useraction_queue_3.connections.group.id' = 'test_group_id';
  2. 例如设置Kafkastart mode
  3. set 'user_info.connections.startup-mode' = 'latest-offset';
  4. 例如设置Kafka表并发
  5. set 'user_action.connector.parallelism' = '2';