跳到主要内容
版本:Latest-4.1

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

相关文档​

Rocky the happy otterStarRocks Assistant

AI generated answers are based on docs and other sources. Please test answers in non-production environments.