diff --git a/zh_CN/sql-reference/statements/show.md b/zh_CN/sql-reference/statements/show.md index 6fade37..598721a 100644 --- a/zh_CN/sql-reference/statements/show.md +++ b/zh_CN/sql-reference/statements/show.md @@ -60,7 +60,6 @@ SHOW PIPELINES | 列名 | 含义 | | --- | --- | | `pipeline_name` | pipeline 名称 | -| `source_name` | pipeline 读取的 source 名称;如果有多个 source,会用逗号拼接 | | `sink_name` | pipeline 写入的 sink 名称 | | `state` | pipeline 当前状态 | | `up_time` | 从启动到当前的运行时长;未启动时为 `-` | diff --git a/zh_CN/streaming/connectors.md b/zh_CN/streaming/connectors.md index 7133fd9..ee8ec89 100644 --- a/zh_CN/streaming/connectors.md +++ b/zh_CN/streaming/connectors.md @@ -29,7 +29,7 @@ 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 @@ -37,7 +37,7 @@ MQTT connector 适合订阅设备、网关或边缘服务上报的主题消息 - 文档入口:[MQTT Connector](./mqtt.md) - format:`json`、`csv` -- metadata:`topic`,以及通用 metadata `source_name` +- metadata:`topic` ### HTTP @@ -45,4 +45,4 @@ HTTP connector 适合按固定周期轮询第三方 API 或内部 HTTP 服务。 - 文档入口:[HTTP Connector](./http.md) - format:`json`、`csv`、`parquet` -- metadata:通用 metadata `source_name` +- metadata:无 diff --git a/zh_CN/streaming/overview.md b/zh_CN/streaming/overview.md index 36d2398..8fee67d 100644 --- a/zh_CN/streaming/overview.md +++ b/zh_CN/streaming/overview.md @@ -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