From 6143794e90e048243f88ee811c6de5cf84a70184 Mon Sep 17 00:00:00 2001 From: Neha Nene Date: Wed, 20 Apr 2022 17:00:02 -0500 Subject: [PATCH] fix: only replaces datatypes and not column names (#453) --- third_party/ibis/ibis_impala/api.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/third_party/ibis/ibis_impala/api.py b/third_party/ibis/ibis_impala/api.py index 80a747dc0..c1bfe0e5d 100644 --- a/third_party/ibis/ibis_impala/api.py +++ b/third_party/ibis/ibis_impala/api.py @@ -62,18 +62,18 @@ def parse_type(t): return ValueError(t) elif "struct" in t or "array" in t or "map" in t: if "bigint" in t: - t = t.replace("bigint", "int64") + t = t.replace(":bigint", ":int64") elif "tinyint" in t: - t = t.replace("tinyint", "int8") + t = t.replace(":tinyint", ":int8") elif "smallint" in t: - t = t.replace("smallint", "int16") + t = t.replace(":smallint", ":int16") else: - t = t.replace("int", "int32") + t = t.replace(":int", ":int32") if "varchar" in t: - t = t.replace("varchar", "string") + t = t.replace(":varchar", ":string") else: - t = t.replace("char","string") + t = t.replace(":char",":string") return t else: raise Exception(t)