[SPARK-42398][SQL][FOLLOWUP] DelegatingCatalogExtension should overri…

…de the new createTable method ### What changes were proposed in this pull request? This is a followup of apache#40049 to fix a small issue: `DelegatingCatalogExtension` should also override the new `createTable` function and call the session catalog, instead of using the default implementation. ### Why are the changes needed? bug fix ### Does this PR introduce _any_ user-facing change? no ### How was this patch tested? N/A, too trivial. Closes apache#40369 from cloud-fan/api. Authored-by: Wenchen Fan <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]>
snmvaughan · Mar 10, 2023 · 061bd92 · 061bd92
1 parent 164db5b
commit 061bd92
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...lyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java b/...lyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java
@@ -102,6 +102,15 @@ public Table createTable(
     return asTableCatalog().createTable(ident, schema, partitions, properties);
   }
 
+  @Override
+  public Table createTable(
+      Identifier ident,
+      Column[] columns,
+      Transform[] partitions,
+      Map<String, String> properties) throws TableAlreadyExistsException, NoSuchNamespaceException {
+    return asTableCatalog().createTable(ident, columns, partitions, properties);
+  }
+
   @Override
   public Table alterTable(
       Identifier ident,