Refactor code

fangbo.0511 · fangbo.0511 · commit 39443c1c6bba · 2025-10-09T15:48:07.000+08:00
diff --git a/lance-spark-base_2.12/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AddColumnsBackfillExec.scala b/lance-spark-base_2.12/src/main/scala/org/apache/spark/sql/execution/datasources/v2/AddColumnsBackfillExec.scala
@@ -33,7 +33,7 @@ case class AddColumnsBackfillExec(
     val table = catalog.loadTable(ident) match {
       case lanceTable: LanceDataset => new LanceDataset(lanceTable.config(), query.schema)
       case _ =>
-        throw new UnsupportedOperationException("AddColumnsAsSelectExec only support LanceDataset")
+        throw new UnsupportedOperationException("AddColumnsBackfill only support LanceDataset")
     }
 
     val relation = DataSourceV2Relation.create(table, Some(catalog), Some(ident))

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ case class AddColumnsBackfillExec(`
`33`	`33`	`val table = catalog.loadTable(ident) match {`
`34`	`34`	`case lanceTable: LanceDataset => new LanceDataset(lanceTable.config(), query.schema)`
`35`	`35`	`case _ =>`
`36`		`- throw new UnsupportedOperationException("AddColumnsAsSelectExec only support LanceDataset")`
	`36`	`+ throw new UnsupportedOperationException("AddColumnsBackfill only support LanceDataset")`
`37`	`37`	`}`
`38`	`38`
`39`	`39`	`val relation = DataSourceV2Relation.create(table, Some(catalog), Some(ident))`