扫描表使用场景

通常，表格将与带有或不带有窗口的流连接。与流连接时，表数据不会影响下游更新数据，它被视为静态引用数据，尽管它可能会在内部更新。

数据补全

表的典型用法是作为查找表。示例 SQL 将类似于：

CREATE TABLE table1 (
    id BIGINT,
    name STRING
  ) WITH (DATASOURCE="lookup.json", FORMAT="JSON", TYPE="file");

SELECT * FROM demo INNER JOIN table1 on demo.id = table1.id

在这个例子中，创建了一个表 table1 来从文件 lookup.json 中读取 json 数据。然后在规则中，将 table1 与流 demo 连接起来，以便流可以从 id 中查找名称。

lookup.json 文件的内容应该是一个对象数组。下面是一个例子：

[
  {
    "id": 1541152486013,
    "name": "name1"
  },
  {
    "id": 1541152487632,
    "name": "name2"
  },
  {
    "id": 1541152489252,
    "name": "name3"
  }
]

按历史状态过滤

在某些情况下，我们可能有一个用于数据的事件流和另一个作为控制信息的事件流。

CREATE TABLE stateTable (
    id BIGINT,
    triggered bool
  ) WITH (DATASOURCE="myTopic", FORMAT="JSON", TYPE="mqtt");

SELECT * FROM demo LEFT JOIN stateTable on demo.id = stateTable.id WHERE triggered=true

在此示例中，创建了一个表 stateTable 来记录来自 mqtt 主题 myTopic 的触发器状态。在规则中，会根据当前触发状态来过滤 demo 流的数据。