ADH-4982

added support arenadata catalog manager
arenadata · Sep 28, 2024 · 83d729d · 83d729d
1 parent 8edf5b4
commit 83d729d
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 1 deletion.
diff --git a/core/trino-main/pom.xml b/core/trino-main/pom.xml
@@ -398,6 +398,12 @@
             <scope>runtime</scope>
         </dependency>
 
+        <dependency>
+            <groupId>io.arenadata</groupId>
+            <artifactId>trino-catalog-manager</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
         <dependency>
             <groupId>net.java.dev.jna</groupId>
             <artifactId>jna-platform</artifactId>

diff --git a/core/trino-main/src/main/java/io/trino/connector/CatalogManagerConfig.java b/core/trino-main/src/main/java/io/trino/connector/CatalogManagerConfig.java
@@ -20,7 +20,7 @@ public class CatalogManagerConfig
 {
     public enum CatalogMangerKind
     {
-        STATIC, DYNAMIC
+        STATIC, DYNAMIC, ARENADATA
     }
 
     private CatalogMangerKind catalogMangerKind = CatalogMangerKind.STATIC;

diff --git a/core/trino-main/src/main/java/io/trino/connector/CatalogManagerModule.java b/core/trino-main/src/main/java/io/trino/connector/CatalogManagerModule.java
@@ -16,6 +16,7 @@
 import com.google.inject.Binder;
 import com.google.inject.Scopes;
 import io.airlift.configuration.AbstractConfigurationAwareModule;
+import io.arenadata.trino.catalog.ArenadataCatalogManagerModule;
 
 import static com.google.inject.multibindings.OptionalBinder.newOptionalBinder;
 
@@ -34,6 +35,7 @@ protected void setup(Binder binder)
         switch (config.getCatalogMangerKind()) {
             case STATIC -> install(new StaticCatalogManagerModule());
             case DYNAMIC -> install(new DynamicCatalogManagerModule());
+            case ARENADATA -> install(new ArenadataCatalogManagerModule());
         }
 
         install(new CatalogServiceProviderModule());