File tree Expand file tree Collapse file tree 2 files changed +4
-0
lines changed
sql/catalyst/src/main/java/org/apache/spark/sql/catalog/v2 Expand file tree Collapse file tree 2 files changed +4
-0
lines changed Original file line number Diff line number Diff line change 1717
1818package org .apache .spark .sql .catalog .v2 ;
1919
20+ import org .apache .spark .annotation .Experimental ;
2021import org .apache .spark .sql .util .CaseInsensitiveStringMap ;
2122
2223/**
2627 * implement {@code createTable}, do something else before calling {@code createTable} of the
2728 * built-in session catalog.
2829 */
30+ @ Experimental
2931public interface CatalogExtension extends TableCatalog {
3032
3133 /**
Original file line number Diff line number Diff line change 1919
2020import java .util .Map ;
2121
22+ import org .apache .spark .annotation .Experimental ;
2223import org .apache .spark .sql .catalog .v2 .expressions .Transform ;
2324import org .apache .spark .sql .catalyst .analysis .NoSuchNamespaceException ;
2425import org .apache .spark .sql .catalyst .analysis .NoSuchTableException ;
3334 * only need to override some methods where they want to apply custom logic. For example, they can
3435 * override {@code createTable}, do something else before calling {@code super.createTable}.
3536 */
37+ @ Experimental
3638public abstract class DelegatingCatalogExtension implements CatalogExtension {
3739
3840 private TableCatalog delegate ;
You can’t perform that action at this time.
0 commit comments