refactor: replace sink_table_id with sink_table_name (#153)

2024-04-26 16:47:57 +08:00
parent 20b85ef113
commit 2c14c6e22d
4 changed files with 239 additions and 228 deletions
@@ -55,11 +55,14 @@ message FlowResponse {
  repeated TaskId affected_tasks = 4;
 }

-// very similar to `ddl.CreateTaskExpr` just replace `task_name` with `task_id`
+// Create a flow task
+// 
+// Very similar to `ddl.CreateTaskExpr`, 
+// replace `source_table_names` with `source_table_ids`
 message CreateRequest {
  TaskId task_id = 1; 
  repeated TableId source_table_ids = 2;
-  TableId sink_table_id = 3;
+  TableName sink_table_name = 3;
  bool create_if_not_exists = 4;
  string expire_when = 5;
  string comment = 6;