Commit Graph

6 Commits

Author SHA1 Message Date
Weny Xu 219b2409bb feat: add flow_id and drop_if_exists to DropFlowExpr (#164)
* feat: add `flow_id` and `drop_if_exists` to `DropFlowExpr`

* chore: apply suggestions from CR

* chore: generate code
2024-05-10 11:32:37 +08:00
Weny Xu e152fcbf17 feat: add QueryContext to DdlTaskRequest and FlowRequestHeader (#166) 2024-05-09 14:27:41 +08:00
Weny Xu b5412f7225 refactor: remove task suffix (#162)
* refactor: remove task suffix

* chore: rename task_options to flow_options
2024-04-29 21:22:55 +08:00
Weny Xu 2c14c6e22d refactor: replace sink_table_id with sink_table_name (#153) 2024-04-26 16:47:57 +08:00
Weny Xu 93ebc1ba90 feat: add source_tables and source_table_ids (#151)
* feat: add `source_tables`

* feat: use `SchemaScopedTableName`

* chore: include flow proto

* chore: rename

* feat: add `CreateFlowTask` and `DropFlowTask`
2024-04-25 17:29:14 +08:00
discord9 5d7db484ce feat: add Create/Remove Task request (#150)
* feat: add Create/Remove Task request

* chore: all supported impls

* feat: flow.server.proto

* feat: add affected task ids

* chore: make all

* chore: typo

* refactor: use u32 for `TaskId`
2024-04-25 14:19:55 +08:00