Skip to main content
Version: nightly

FLOWS

The Flows table provides the flow task information.

DESC TABLE INFORMATION_SCHEMA.FLOWS;
      Column      |  Type  | Key | Null | Default | Semantic Type 
------------------+--------+-----+------+---------+---------------
 flow_name        | String |     | NO   |         | FIELD
 flow_id          | UInt32 |     | NO   |         | FIELD
 table_catalog    | String |     | NO   |         | FIELD
 flow_definition  | String |     | NO   |         | FIELD
 comment          | String |     | YES  |         | FIELD
 expire_after     | Int64  |     | YES  |         | FIELD
 source_table_ids | String |     | YES  |         | FIELD
 sink_table_name  | String |     | NO   |         | FIELD
 flownode_ids     | String |     | YES  |         | FIELD
 options          | String |     | YES  |         | FIELD
(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.