diff --git a/trino/sqlalchemy/compiler.py b/trino/sqlalchemy/compiler.py index 8747d190..cec43e2f 100644 --- a/trino/sqlalchemy/compiler.py +++ b/trino/sqlalchemy/compiler.py @@ -196,6 +196,9 @@ def visit_TIME(self, type_, **kw): def visit_JSON(self, type_, **kw): return 'JSON' + def visit_MAP(self, type_, **kw): + return 'MAP' + class TrinoIdentifierPreparer(compiler.IdentifierPreparer): reserved_words = RESERVED_WORDS