getStreamingSQLStatus

getStreamingSQLStatus([queryId])

queryId 可选参数，字符串标量，表示已注册的流式 SQL 查询 ID。

查看流式 SQL 查询的运行状态。

• 若指定 queryId，则返回该查询的状态。
• 若不指定 queryId，返回当前用户注册的所有流式 SQL 查询的状态。如果调用者是管理员（admin），则返回所有用户注册的流式 SQL 查询的状态。

返回值：一个表，包含如下字段：

• queryId：流式 SQL 查询的 ID。
• user：注册该查询的用户名。
• registerTime：注册该查询的时间。
• status：当前查询的状态，取值包括：
  • SQL_REGISTERED：已注册，未运行。
  • SQL_RUNNING：正常运行中，结果实时更新。
  • SQL_STOPPED：已暂停。
  • INTERNAL_ERROR：运行异常。
• sqlQuery：流式 SQL 查询的语句。
• involvedTables：查询涉及的表。
• lastErrorMessage：最近一次错误的信息（如有）。

t=table(1..10 as id,rand(100,10) as val)
share t as st
declareStreamingSQLTable(st)
registerStreamingSQL("select avg(val) from st","sql_avg") 

// 查看流式 SQL 查询的状态
getStreamingSQLStatus("sql_avg")

相关函数：declareStreamingSQLTable, registerStreamingSQL