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 任务的其他额外选项。