add start time to tumble function

GreptimeTeam · May 20, 2024 · bb3fdac · bb3fdac
1 parent 0ccba22
commit bb3fdac
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/docs/nightly/en/user-guide/continuous-aggregation/manage-flow.md b/docs/nightly/en/user-guide/continuous-aggregation/manage-flow.md
@@ -58,7 +58,7 @@ CREATE FLOW IF NOT EXISTS my_flow
 OUTPUT TO my_sink_table
 COMMENT = "My first flow in GreptimeDB"
 AS
-SELECT count(item) from my_source_table GROUP BY tumble(time_index, INTERVAL '5 minutes');
+SELECT count(item) from my_source_table GROUP BY tumble(time_index, INTERVAL '5 minutes', '2024-05-20 00:00:00');
 ```
 
 The created flow will compute `count(item)` for every 5 minutes and store the result in `my_sink_table`. For the `tumble()` function, refer to [define time window](./define-time-window.md) part.

diff --git a/docs/nightly/zh/user-guide/continuous-aggregation/manage-flow.md b/docs/nightly/zh/user-guide/continuous-aggregation/manage-flow.md
@@ -7,7 +7,7 @@
 一个 `flow` 有以下属性：
 - `name`: flow 的名称。在目录级别中是唯一的标识符。
 - `source tables`: 为 flow 提供数据的表。每个 flow 可以有多个 source 表。
-- `sink table`: 存储聚合数据的表。
+- `sink table`: 存储聚合数据的结果表。
 <!-- - `expire after`: 从 source 表中过期数据的时间间隔。过期时间之后的数据将不会在 flow 中使用。 -->
 - `comment`: flow 的描述。
 - `SQL`: 定义 flow 的连续聚合查询。有关可用表达式，请参阅 [表达式](./expression.md)。
@@ -62,7 +62,7 @@ CREATE FLOW IF NOT EXISTS my_flow
 OUTPUT TO my_sink_table
 COMMENT = "My first flow in GreptimeDB"
 AS
-SELECT count(item) from my_source_table GROUP BY tumble(time_index, INTERVAL '5 minutes');
+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` 中。