apache druid datasource

Canner · Nov 6, 2024 · b8830fe · b8830fe
1 parent eac8be8
commit b8830fe
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 18 deletions.
diff --git a/ibis-server/app/model/__init__.py b/ibis-server/app/model/__init__.py
@@ -49,10 +49,6 @@ class QuerySnowflakeDTO(QueryDTO):
 class QueryDruidDTO(QueryDTO):
     connection_info: DruidConnectionInfo = connection_info_field
 
-class QueryDruidDTO(QueryDTO):
-    connection_info: DruidConnectionInfo = connection_info_field
-
-
 class QueryTrinoDTO(QueryDTO):
     connection_info: ConnectionUrl | TrinoConnectionInfo = connection_info_field
 
@@ -86,12 +82,6 @@ class DruidConnectionInfo(BaseModel):
     port: SecretStr = Field(examples=[8082])
     path: str
 
-class DruidConnectionInfo(BaseModel):
-    host: SecretStr = Field(examples=["localhost"])
-    port: SecretStr = Field(examples=[8082])
-    path: str
-
-
 class MSSqlConnectionInfo(BaseModel):
     host: SecretStr
     port: SecretStr

diff --git a/ibis-server/app/model/data_source.py b/ibis-server/app/model/data_source.py
@@ -121,14 +121,6 @@ def get_druid_connection(info: DruidConnectionInfo) -> BaseBackend:
             path=info.path,
         )
 
-    @staticmethod
-    def get_druid_connection(info: DruidConnectionInfo) -> BaseBackend:
-        return ibis.druid.connect(
-            host=info.host.get_secret_value(),
-            port=int(info.port.get_secret_value()),
-            path=info.path,
-        )
-
     @classmethod
     def get_mssql_connection(cls, info: MSSqlConnectionInfo) -> BaseBackend:
         return ibis.mssql.connect(