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;
语句查看是否删除成功。
文档内容是否对您有帮助?