FLOWS

Flows 表提供了 Flow 任务的相关信息。

  1. DESC TABLE INFORMATION_SCHEMA.FLOWS;
  1.       Column      |  Type  | Key | Null | Default | Semantic Type 
  2. ------------------+--------+-----+------+---------+---------------
  3.  flow_name        | String |     | NO   |         | FIELD
  4.  flow_id          | UInt32 |     | NO   |         | FIELD
  5.  table_catalog    | String |     | NO   |         | FIELD
  6.  flow_definition  | String |     | NO   |         | FIELD
  7.  comment          | String |     | YES  |         | FIELD
  8.  expire_after     | Int64  |     | YES  |         | FIELD
  9.  source_table_ids | String |     | YES  |         | FIELD
  10.  sink_table_name  | String |     | NO   |         | FIELD
  11.  flownode_ids     | String |     | YES  |         | FIELD
  12.  options          | String |     | YES  |         | FIELD
  13. (10 rows)

表中的列：

  • flow_name: Flow 任务的名称。
  • flow_id: Flow 任务的 id。
  • table_catalog: 该 Flow 所属的目录，命名为 table_catalog 以保持与 INFORMATION_SCHEMA 标准一致。
  • flow_definition: Flow 任务的定义，是用于创建 Flow 任务的 SQL 语句。
  • comment: Flow 任务的注释。
  • expire_after: Flow 任务的过期时间。
  • source_table_ids: Flow 任务的源表 id。
  • sink_table_name: Flow 任务的目标表名称。
  • flownode_ids: Flow 任务使用的 flownode id。
  • options: Flow 任务的其他额外选项。