Enhancement: Fix compatibility issues with Spark 3.2.

yuanoOo · yuanoOo · commit 0fc505a4483d · 2025-04-27T10:53:50.000+08:00
diff --git a/spark-connector-oceanbase/spark-connector-oceanbase-3.2/src/main/scala/com/oceanbase/spark/reader/v2/OBJdbcScanBuilder.scala b/spark-connector-oceanbase/spark-connector-oceanbase-3.2/src/main/scala/com/oceanbase/spark/reader/v2/OBJdbcScanBuilder.scala
@@ -77,9 +77,6 @@ case class OBJdbcScanBuilder(
     false
   }
 
-  // Always partially pushdown.
-  override def isPartiallyPushed: Boolean = true
-
   override def build(): Scan =
     OBJdbcBatchScan(
       finalSchema: StructType,

Original file line number	Diff line number	Diff line change
`@@ -77,9 +77,6 @@ case class OBJdbcScanBuilder(`
`77`	`77`	`false`
`78`	`78`	`}`
`79`	`79`
`80`		`- // Always partially pushdown.`
`81`		`- override def isPartiallyPushed: Boolean = true`
`82`		`-`
`83`	`80`	`override def build(): Scan =`
`84`	`81`	`OBJdbcBatchScan(`
`85`	`82`	`finalSchema: StructType,`