DROP PIPE

DROP PIPE语法用于删除Lindorm消息引擎中已存在的Mirror Link链路。

引擎与版本

  • DROP PIPE仅适用于消息引擎。

  • 消息引擎3.8.0及以上版本支持DROP PIPE语法。

重要

要求Lindorm SQL为2.7.0以上版本。如何查看Lindorm SQL的版本,请参见SQL版本说明

语法

drop_pipe_statement   ::= DROP PIPE pipe_identifier

使用说明

说明

DROP PIPE语句暂不支持指定IF EXISTS子句。

Mirror Link链路名(pipe_identifier)

已存在的Mirror Link链路名。如果指定了一个不存在的链路名,则会报错。

示例

删除名为pip1的Mirror Link链路。

-- 创建Mirror Link链路
CREATE PIPE pip1 AS
  COPY FROM sourceTopic@'broker-1:90992'
WITH (
  `scan.startup.mode` = 'timestamp',
  `scan.startup.timestamp-millis` = '1708910643000'
);

-- 删除链路
DROP PIPE pip1;

结果验证

您可以通过SHOW PIPES;语句查看是否删除成功。