Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion zh_CN/sql-reference/statements/show.md
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,6 @@ SHOW PIPELINES
| 列名 | 含义 |
| --- | --- |
| `pipeline_name` | pipeline 名称 |
| `source_name` | pipeline 读取的 source 名称;如果有多个 source,会用逗号拼接 |
| `sink_name` | pipeline 写入的 sink 名称 |
| `state` | pipeline 当前状态 |
| `up_time` | 从启动到当前的运行时长;未启动时为 `-` |
Expand Down
6 changes: 3 additions & 3 deletions zh_CN/streaming/connectors.md
Original file line number Diff line number Diff line change
Expand Up @@ -29,20 +29,20 @@ Kafka connector 适合持续消费 topic 中的结构化事件流。

- 文档入口:[Kafka Connector](./kafka.md)
- format:`json`、`csv`
- metadata:`topic`、`partition`、`offset`,以及所有 source 都支持的通用 metadata `source_name`。其中 `source_name` 是 source 的名称,可以在 create source 时通过 `METADATA FROM 'source_name'` 引用
- metadata:`topic`、`partition`、`offset`

### MQTT

MQTT connector 适合订阅设备、网关或边缘服务上报的主题消息。

- 文档入口:[MQTT Connector](./mqtt.md)
- format:`json`、`csv`
- metadata:`topic`,以及通用 metadata `source_name`
- metadata:`topic`

### HTTP

HTTP connector 适合按固定周期轮询第三方 API 或内部 HTTP 服务。

- 文档入口:[HTTP Connector](./http.md)
- format:`json`、`csv`、`parquet`
- metadata:通用 metadata `source_name`
- metadata:
1 change: 0 additions & 1 deletion zh_CN/streaming/overview.md
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,6 @@ Kafka / MQTT / HTTP
CREATE SOURCE src_kafka (
ts TIMESTAMP(9),
sid STRING,
source_name STRING METADATA FROM 'source_name',
source_topic STRING METADATA FROM 'topic',
topic_tag STRING AS source_topic,
value FLOAT64
Expand Down