FLOWS

The Flows table provides the flow task information.

  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)

The columns in table:

  • flow_name: the flow task’s name.
  • flow_id: the flow task’s id.
  • table_catalog: the catalog this flow belongs to, named as table_catalog to keep consistent with the INFORMATION_SCHEMA standard.
  • flow_definition: the flow task’s definition. It’s the SQL statement used to create the flow task.
  • comment: the comment of the flow task.
  • expire_after: the expire time of the flow task.
  • source_table_ids: the source table ids of the flow task.
  • sink_table_name: the sink table name of the flow task.
  • flownode_ids: the flownode ids used by the flow task.
  • options: extra options of the flow task.