aokolnychyi commented on code in PR #55586:
URL: https://github.com/apache/spark/pull/55586#discussion_r3220566860
##########
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/v2Commands.scala:
##########
@@ -194,6 +194,26 @@ object AppendData {
}
}
+/**
+ * Append data to an existing table as the result of an insert-only MERGE
rewrite.
+ *
+ * Functionally equivalent to [[AppendData]] but distinguishes the row-level
MERGE rewrite path.
+ */
+case class InsertOnlyMerge(
+ table: NamedRelation,
+ query: LogicalPlan,
+ write: Option[Write] = None,
+ analyzedQuery: Option[LogicalPlan] = None) extends V2WriteCommand with
TransactionalWrite {
Review Comment:
Does this have to extend `TransactionalWrite`? I believe `MergeIntoTable` is
the one that triggers the transaction. @andreaschat-db, thoughts?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
