SHOW PIPES语句用于展示Lindorm消息引擎中已存在的Mirror Link链路。
引擎与版本
SHOW PIPES语法仅适用于消息引擎。消息引擎3.8.0及以上版本支持
SHOW PIPES语法。
重要
要求Lindorm SQL为2.7.0以上版本。如何查看Lindorm SQL的版本，请参见SQL版本说明。
语法
show_pipes_statement ::= SHOW PIPES返回结果集说明
语句执行结果会通过表的形式进行呈现，表的字段如下：
字段 | 说明 |
PIPE_NAME | Mirror Link链路名。 |
SINK_TABLE | 数据导入链路的目标流表名。 |
SOURCE_TOPIC | 数据导入链路的源Kafka主题名。 |
SOURCE_SERVERS | 数据导入链路的源Kafka集群地址。 |
START_TIMESTAMP | 数据导入开始时间戳。 |
PIPE_PROPERTIES | 链路属性明细。 |
示例
展示当前所有Mirror Link链路。
SHOW PIPES;返回结果：
+-----------+------------+--------------+----------------+-----------------+-----------------------------------------------------------------------------------+
| PIPE_NAME | SINK_TABLE | SOURCE_TOPIC | SOURCE_SERVERS | START_TIMESTAMP | PIPE_PROPERTIES |
+-----------+------------+--------------+----------------+-----------------+-----------------------------------------------------------------------------------+
| pip1 | sinkTopic | source | stream-1:30080 | 1716457998944 | {"scan.startup.mode":"timestamp","scan.startup.timestamp-millis":"1708910643000"} |
+-----------+------------+--------------+----------------+-----------------+-----------------------------------------------------------------------------------+文档内容是否对您有帮助？