aokolnychyi commented on a change in pull request #29066:
URL: https://github.com/apache/spark/pull/29066#discussion_r537575760
##########
File path:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/WriteToDataSourceV2Exec.scala
##########
@@ -322,6 +322,27 @@ trait BatchWriteHelper {
}
}
+trait V2ExistingTableWriteExec extends V2TableWriteExec {
+ def session: SparkSession
+ def relation: DataSourceV2Relation
+ def write: Option[BatchWrite] = None
Review comment:
I kept it as `Option` just in case we don't want to apply the new logic
all the time and will introduce a flag to fallback to the old approach. If we
are not going to have that flag, we can make this required.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
