跳到主要内容
版本：Stable-3.3

SHOW PIPES

功能​

查看当前数据库或指定数据库下 Pipe。该命令自 3.2 版本起支持。

语法​

SHOW PIPES [FROM <db_name>]
[
   WHERE [ NAME { = "<pipe_name>" | LIKE "pipe_matcher" } ]
         [ [AND] STATE = { "SUSPENDED" | "RUNNING" | "ERROR" } ]
]
[ ORDER BY <field_name> [ ASC | DESC ] ]
[ LIMIT { [offset, ] limit | limit OFFSET offset } ]

参数说明​

FROM <db_name>​

指定待查询数据库的名称。如果不指定数据库，则默认查询当前数据库下的 Pipe。

WHERE​

指定查询条件。

ORDER BY <field_name>​

指定结果记录的排序字段。

LIMIT​

指定系统返回的最大结果记录数。

返回结果​

返回结果包括如下字段：

字段说明
DATABASE_NAMEPipe 所属数据库的名称。
IDPipe 的唯一 ID。
NAMEPipe 的名称。
TABLE_NAMEStarRocks 目标表的名称。
STATEPipe 的状态，包括 RUNNING、FINISHED、SUSPENDED、ERROR。
LOAD_STATUSPipe 下待导入数据文件的整体状态，包括如下字段：
  • loadedFiles：已导入的数据文件总个数。
  • loadedBytes：已导入的数据总量，单位为字节。
  • LastLoadedTime：最近一次执行导入的时间。格式：yyyy-MM-dd HH:mm:ss。例如，2023-07-24 14:58:58。
LAST_ERRORPipe 执行过程中最近一次错误的详细信息。默认值为 NULL。
CREATED_TIMEPipe 的创建时间。格式：yyyy-MM-dd HH:mm:ss。例如：2023-07-24 14:58:58。

示例​

查询所有 Pipe​

进入数据库 mydatabase，然后查看该数据库下所有 Pipe：

USE mydatabase;
SHOW PIPES \G

查询指定 Pipe​

进入数据库 mydatabase，然后查看该数据库下名为 user_behavior_replica 的 Pipe：

USE mydatabase;
SHOW PIPES WHERE NAME = 'user_behavior_replica' \G

相关文档​