yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-10-14 10:18:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add lineage dialect for Exasol, Trino and Vertica (#21604)

Browse Source 
(cherry picked from commit ea63db993a596a307bc688399f02da6b64935111)
This commit is contained in:
Mohit Tilala 2025-06-06 11:48:52 +05:30 committed by OpenMetadata Release Bot
parent 744632cc03
commit 745ff15e91
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ingestion/src/metadata/ingestion/lineage/models.py
View File

@ -37,6 +37,9 @@ from metadata.generated.schema.entity.services.connections.database.db2Connectio
from metadata.generated.schema.entity.services.connections.database.deltaLakeConnection import ( from metadata.generated.schema.entity.services.connections.database.deltaLakeConnection import (
DeltaLakeType, DeltaLakeType,
) )
from metadata.generated.schema.entity.services.connections.database.exasolConnection import (
ExasolType,
)
from metadata.generated.schema.entity.services.connections.database.hiveConnection import ( from metadata.generated.schema.entity.services.connections.database.hiveConnection import (
HiveType, HiveType,
) )
@ -73,9 +76,15 @@ from metadata.generated.schema.entity.services.connections.database.sqliteConnec
from metadata.generated.schema.entity.services.connections.database.teradataConnection import ( from metadata.generated.schema.entity.services.connections.database.teradataConnection import (
TeradataType, TeradataType,
) )
from metadata.generated.schema.entity.services.connections.database.trinoConnection import (
TrinoType,
)
from metadata.generated.schema.entity.services.connections.database.unityCatalogConnection import ( from metadata.generated.schema.entity.services.connections.database.unityCatalogConnection import (
DatabricksType as UnityCatalogType, DatabricksType as UnityCatalogType,
) )
from metadata.generated.schema.entity.services.connections.database.verticaConnection import (
VerticaType,
)
from metadata.utils.singleton import Singleton from metadata.utils.singleton import Singleton
@ -106,6 +115,8 @@ class Dialect(Enum):
TERADATA = "teradata" TERADATA = "teradata"
TSQL = "tsql" TSQL = "tsql"
MARIADB = "mariadb" MARIADB = "mariadb"
TRINO = "trino"
VERTICA = "vertica"
MAP_CONNECTION_TYPE_DIALECT: Dict[str, Dialect] = { MAP_CONNECTION_TYPE_DIALECT: Dict[str, Dialect] = {
@ -129,6 +140,9 @@ MAP_CONNECTION_TYPE_DIALECT: Dict[str, Dialect] = {
str(TeradataType.Teradata.value): Dialect.TERADATA, str(TeradataType.Teradata.value): Dialect.TERADATA,
str(MariaDBType.MariaDB.value): Dialect.MARIADB, str(MariaDBType.MariaDB.value): Dialect.MARIADB,
str(SingleStoreType.SingleStore.value): Dialect.MYSQL, str(SingleStoreType.SingleStore.value): Dialect.MYSQL,
str(ExasolType.Exasol.value): Dialect.EXASOL,
str(TrinoType.Trino.value): Dialect.TRINO,
str(VerticaType.Vertica.value): Dialect.VERTICA,
} }