aokolnychyi commented on code in PR #55278:
URL: https://github.com/apache/spark/pull/55278#discussion_r3164946933
##########
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala:
##########
@@ -1024,17 +1053,43 @@ class Analyzer(
// Unwrap temp views storing analyzed plans and resolve V2TableReference
nodes in the child.
private def unwrapRelationPlan(plan: LogicalPlan): LogicalPlan = {
EliminateSubqueryAliases(plan) match {
- case v: View if v.isTempViewStoringAnalyzedPlan =>
resolveTableReferences(v.child)
+ case v: View if v.isTempViewStoringAnalyzedPlan =>
resolveTableReferencesInTempView(v.child)
case other => other
}
}
- // Resolve V2TableReference nodes in a plan. V2TableReference is only
created for temp views
- // (via V2TableReference.createForTempView), so we only need to resolve it
when returning
+ // Resolve the write target of a V2 write command (batch or streaming).
+ private def resolveWriteTarget(
Review Comment:
I am not sure I understand the purpose of this method.
Won't this always be a no-op for `StreamingV2WriteCommand`? Why add then?
--
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]
