Add comment explaining affected_table_change field in CreateSinkRequest.

risingwavelabs · Nov 24, 2023 · b905cd5 · b905cd5
1 parent 9119ec3
commit b905cd5
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/proto/ddl_service.proto b/proto/ddl_service.proto
@@ -77,10 +77,10 @@ message AlterSourceResponse {
   uint64 version = 2;
 }
 
-
 message CreateSinkRequest {
   catalog.Sink sink = 1;
   stream_plan.StreamFragmentGraph fragment_graph = 2;
+  // It is used to provide a replace plan for the downstream table in `create sink into table` requests.
   optional ReplaceTablePlan affected_table_change = 3;
 }
 

diff --git a/proto/stream_plan.proto b/proto/stream_plan.proto
@@ -90,7 +90,6 @@ message ThrottleMutation {
   map<uint32, RateLimit> actor_throttle = 1;
 }
 
-
 message CombinedMutation {
   repeated BarrierMutation mutations = 1;
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -90,7 +90,6 @@ message ThrottleMutation { @@
       map<uint32, RateLimit> actor_throttle = 1;
     }
     message CombinedMutation {
       repeated BarrierMutation mutations = 1;
     }
@@ Expand Down @@