Skip to content

Commit bd12077

Browse files
committed
docs(cn): simplify step headings
1 parent 4b3ce6a commit bd12077

File tree

2 files changed

+18
-18
lines changed

2 files changed

+18
-18
lines changed

docs/cn/guides/40-load-data/05-continuous-data-pipelines/01-stream.md

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ Stream 不复制整张表,只保留“尚未消费的增量”。消费由谁
1616

1717
## 示例 1:Append-Only Stream
1818

19-
### Step 1. 创建基表与 Stream
19+
### 步骤 1: 创建基表与 Stream
2020

2121
```sql
2222
CREATE OR REPLACE TABLE sensor_readings (
@@ -28,7 +28,7 @@ CREATE OR REPLACE STREAM sensor_readings_stream
2828
ON TABLE sensor_readings; -- APPEND_ONLY 默认即为 true
2929
```
3030

31-
### Step 2. 插入并查看增量
31+
### 步骤 2: 插入并查看增量
3232

3333
```sql
3434
INSERT INTO sensor_readings VALUES (1, 21.5), (2, 19.7);
@@ -46,7 +46,7 @@ FROM sensor_readings_stream;
4646
└────────────┴───────────────┴───────────────┴──────────────────┘
4747
```
4848

49-
### Step 3. 消费并写入目标表
49+
### 步骤 3: 消费并写入目标表
5050

5151
```sql
5252
CREATE OR REPLACE TABLE sensor_readings_latest AS
@@ -58,15 +58,15 @@ SELECT * FROM sensor_readings_stream; -- 已为空
5858

5959
## 示例 2:Standard Stream(含 UPDATE / DELETE)
6060

61-
### Step 1. 为同一张表建立 Standard Stream
61+
### 步骤 1: 为同一张表建立 Standard Stream
6262

6363
```sql
6464
CREATE OR REPLACE STREAM sensor_readings_stream_std
6565
ON TABLE sensor_readings
6666
APPEND_ONLY = false;
6767
```
6868

69-
### Step 2. 执行 UPDATE / DELETE / INSERT 并比较两个 Stream
69+
### 步骤 2: 执行 UPDATE / DELETE / INSERT 并比较两个 Stream
7070

7171
```sql
7272
UPDATE sensor_readings SET temperature = 22 WHERE sensor_id = 1; -- 更新
@@ -97,7 +97,7 @@ ORDER BY change$row_id;
9797

9898
多条 Stream 可以在需要时“一次性消费”。借助 `WITH CONSUME`,每次只处理尚未消费的增量,既适合批式作业也能容忍不同步到达的变更。
9999

100-
### Step 1. 创建基表与 Stream
100+
### 步骤 1: 创建基表与 Stream
101101

102102
```sql
103103
CREATE OR REPLACE TABLE customers (
@@ -116,7 +116,7 @@ CREATE OR REPLACE STREAM customers_stream ON TABLE customers;
116116
CREATE OR REPLACE STREAM orders_stream ON TABLE orders;
117117
```
118118

119-
### Step 2. 首批数据
119+
### 步骤 2: 首批数据
120120

121121
```sql
122122
INSERT INTO customers VALUES
@@ -130,7 +130,7 @@ INSERT INTO orders VALUES
130130
(5003, 102, 89.0);
131131
```
132132

133-
### Step 3. 第一次增量聚合
133+
### 步骤 3: 第一次增量聚合
134134

135135
```sql
136136
WITH
@@ -162,7 +162,7 @@ ORDER BY o.customer_id;
162162
└──────────────┴───────────┴────────────────────┘
163163
```
164164

165-
### Step 4. 下一批到达后再次运行
165+
### 步骤 4: 下一批到达后再次运行
166166

167167
```sql
168168
INSERT INTO customers VALUES (104, 'Standard', 'Guangzhou');

docs/cn/guides/40-load-data/05-continuous-data-pipelines/02-task.md

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ Task 是“把 SQL 交给 Databend 代跑”的方式。你可以让它按固定
2222

2323
持续生成 Parquet 并导入表。记得把 `'etl_wh_small'` 换成你自己的 Warehouse。
2424

25-
### Step 1. 准备演示对象
25+
### 步骤 1: 准备演示对象
2626

2727
```sql
2828
CREATE DATABASE IF NOT EXISTS task_demo;
@@ -38,7 +38,7 @@ CREATE OR REPLACE TABLE sensor_events (
3838
CREATE OR REPLACE STAGE sensor_events_stage;
3939
```
4040

41-
### Step 2. Task 1 —— 生成文件
41+
### 步骤 2: Task 1 —— 生成文件
4242

4343
```sql
4444
CREATE OR REPLACE TASK task_generate_data
@@ -57,7 +57,7 @@ FROM (
5757
FILE_FORMAT = (TYPE = PARQUET);
5858
```
5959

60-
### Step 3. Task 2 —— 将文件导入表
60+
### 步骤 3: Task 2 —— 将文件导入表
6161

6262
```sql
6363
CREATE OR REPLACE TASK task_consume_data
@@ -71,14 +71,14 @@ FILE_FORMAT = (TYPE = PARQUET)
7171
PURGE = TRUE;
7272
```
7373

74-
### Step 4. 恢复 Task
74+
### 步骤 4: 恢复 Task
7575

7676
```sql
7777
ALTER TASK task_generate_data RESUME;
7878
ALTER TASK task_consume_data RESUME;
7979
```
8080

81-
### Step 5. 观察运行情况
81+
### 步骤 5: 观察运行情况
8282

8383
```sql
8484
SHOW TASKS LIKE 'task_%';
@@ -87,7 +87,7 @@ SELECT * FROM sensor_events ORDER BY event_time DESC LIMIT 5;
8787
SELECT * FROM task_history('task_consume_data', 5);
8888
```
8989

90-
### Step 6. 调整或改写 Task
90+
### 步骤 6: 调整或改写 Task
9191

9292
```sql
9393
ALTER TASK task_consume_data
@@ -111,7 +111,7 @@ ORDER BY completed_time DESC;
111111

112112
只有当 Stream 报告“有增量”时才运行,避免空跑。
113113

114-
### Step 1. 创建 Stream 与结果表
114+
### 步骤 1: 创建 Stream 与结果表
115115

116116
```sql
117117
CREATE OR REPLACE STREAM sensor_events_stream
@@ -124,7 +124,7 @@ FROM sensor_events
124124
WHERE 1 = 0;
125125
```
126126

127-
### Step 2. 定义条件 Task
127+
### 步骤 2: 定义条件 Task
128128

129129
```sql
130130
CREATE OR REPLACE TASK task_stream_merge
@@ -139,7 +139,7 @@ FROM sensor_events_stream;
139139
ALTER TASK task_stream_merge RESUME;
140140
```
141141

142-
### Step 3. 查看增量与历史
142+
### 步骤 3: 查看增量与历史
143143

144144
```sql
145145
SELECT *

0 commit comments

Comments
 (0)