[spark] branch master updated: [SPARK-42398][SQL][FOLLOWUP] DelegatingCatalogExtension should override the new createTable method

[dongjoon]

This is an automated email from the ASF dual-hosted git repository.

dongjoon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/master by this push:
     new 061bd92375a [SPARK-42398][SQL][FOLLOWUP] DelegatingCatalogExtension 
should override the new createTable method
061bd92375a is described below

commit 061bd92375ae9232c9b901ab0760f9712790c26f
Author: Wenchen Fan <wenc...@databricks.com>
AuthorDate: Fri Mar 10 13:00:14 2023 -0800

    [SPARK-42398][SQL][FOLLOWUP] DelegatingCatalogExtension should override the 
new createTable method
    
    ### What changes were proposed in this pull request?
    
    This is a followup of https://github.com/apache/spark/pull/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 #40369 from cloud-fan/api.
    
    Authored-by: Wenchen Fan <wenc...@databricks.com>
    Signed-off-by: Dongjoon Hyun <dongj...@apache.org>
---
 .../spark/sql/connector/catalog/DelegatingCatalogExtension.java  | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java
 
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java
index 534e1b86eca..f6686d2e4d3 100644
--- 
a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java
+++ 
b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java
@@ -102,6 +102,15 @@ public abstract class DelegatingCatalogExtension 
implements CatalogExtension {
     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,


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org