cloud-fan commented on code in PR #50806:
URL: https://github.com/apache/spark/pull/50806#discussion_r2077142737
##########
sql/catalyst/src/test/scala/org/apache/spark/sql/connector/catalog/InMemoryBaseTable.scala:
##########
@@ -60,6 +62,27 @@ abstract class InMemoryBaseTable(
val numRowsPerSplit: Int = Int.MaxValue)
extends Table with SupportsRead with SupportsWrite with
SupportsMetadataColumns {
+ protected var currentTableVersion: Int = 0
+ private var validatedTableVersion: String = null
+
+ override def currentVersion(): String = currentTableVersion.toString
+
+ def setCurrentVersion(version: String): Unit = {
+ currentTableVersion = version.toInt
+ }
+
+ def increaseCurrentVersion(): Unit = {
+ currentTableVersion += 1
+ }
+
+ def validatedVersion(): String = {
Review Comment:
why do we need it? The added test doesn't even check it.
--
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
