diff --git a/pyhive/sqlalchemy_hive.py b/pyhive/sqlalchemy_hive.py index 2ef49652..c7f000a3 100644 --- a/pyhive/sqlalchemy_hive.py +++ b/pyhive/sqlalchemy_hive.py @@ -194,6 +194,12 @@ def visit_CLOB(self, type_): def visit_BLOB(self, type_): return 'BINARY' + def visit_BINARY(self, type_): + return 'BINARY' + + def visit_VARBINARY(self, type_): + return self.visit_BINARY(type_) + def visit_TIME(self, type_): return 'TIMESTAMP'