跳到主要内容
版本:3.2

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 的状态,包括 RUNNINGFINISHEDSUSPENDEDERROR
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

相关文档