Skip to content

Commit f5c8a68

Browse files
committed
Review feedback
1 parent 92cea9b commit f5c8a68

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RelationResolution.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -253,6 +253,7 @@ class RelationResolution(override val catalogManager: CatalogManager)
253253
private def adaptCachedRelation(cached: LogicalPlan, ref: V2TableReference): LogicalPlan = {
254254
cached transform {
255255
case r: DataSourceV2Relation if matchesReference(r, ref) =>
256+
V2TableReferenceUtils.validateLoadedTable(r.table, ref)
256257
r.copy(output = ref.output, options = ref.options)
257258
}
258259
}

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/V2TableReference.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ import org.apache.spark.util.ArrayImplicits._
4848
* For instance, temporary views with fully resolved logical plans don't allow schema changes
4949
* in underlying tables.
5050
*/
51-
case class V2TableReference private(
51+
private[sql] case class V2TableReference private(
5252
catalog: TableCatalog,
5353
identifier: Identifier,
5454
options: CaseInsensitiveStringMap,
@@ -75,7 +75,7 @@ case class V2TableReference private(
7575
}
7676
}
7777

78-
object V2TableReference {
78+
private[sql] object V2TableReference {
7979

8080
case class TableInfo(
8181
columns: Seq[Column],
@@ -103,7 +103,7 @@ object V2TableReference {
103103
}
104104
}
105105

106-
object V2TableReferenceUtils extends SQLConfHelper {
106+
private[sql] object V2TableReferenceUtils extends SQLConfHelper {
107107

108108
def validateLoadedTable(table: Table, ref: V2TableReference): Unit = {
109109
ref.context match {

0 commit comments

Comments
 (0)