Skip to content

Commit

Permalink
flow example
Browse files Browse the repository at this point in the history
  • Loading branch information
nicecui committed May 28, 2024
1 parent de7b8f8 commit 90c22e8
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -59,10 +59,7 @@ AS
SELECT count(item) from my_source_table GROUP BY tumble(time_index, INTERVAL '5 minutes', '2024-05-20 00:00:00');
```

该 Flow 将每 5 分钟计算 `count(item)` 并将结果存储在 `my_sink_table` 中。
有关 `tumble()` 函数,请参考[定义时间窗口](./define-time-window.md) 部分。

<!-- 创建的 flow 将每 5 分钟计算 `count(item)` 并将结果存储在 `my_sink_table` 中。所有在 1 小时内的数据将在 flow 中使用。有关 `tumble()` 函数,请参考[定义时间窗口](./define-time-window.md) 部分。 -->
创建的 flow 将每 5 分钟计算 `count(item)` 并将结果存储在 `my_sink_table` 中。所有在 1 小时内的数据将在 flow 中使用。有关 `tumble()` 函数,请参考[定义时间窗口](./define-time-window.md) 部分。

### `EXPIRE AFTER` 语句

Expand Down

0 comments on commit 90c22e8

Please sign in to comment.