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.