HyukjinKwon commented on code in PR #46960:
URL: https://github.com/apache/spark/pull/46960#discussion_r1664900423
##########
connector/connect/common/src/main/protobuf/spark/connect/commands.proto:
##########
@@ -504,3 +505,26 @@ message CheckpointCommand {
// (Required) Whether to checkpoint this dataframe immediately.
bool eager = 3;
}
+
+message MergeIntoTableCommand {
+ // (Required) The name of the target table.
+ string target_table_name = 1;
+
+ // (Required) The relation of the source table.
+ Relation source_table_plan = 2;
+
+ // (Required) The condition to match the source and target.
+ Expression merge_condition = 3;
+
+ // (Optional) The actions to be taken when the condition is matched.
+ repeated Expression match_actions = 4;
+
+ // (Optional) The actions to be taken when the condition is not matched.
+ repeated Expression not_matched_actions = 5;
+
+ // (Optional) The actions to be taken when the condition is not matched by
source.
+ repeated Expression not_matched_by_source_actions = 6;
+
+ // (Required) Whether to enable schema evolution.
+ bool with_schema_evolution = 7;
+}
Review Comment:
This would need some reviews from @hvanhovell and/or @grundprinzip
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
