change âfloatâ to âdoubleâ when sync a hive table into kylin
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/a540605e Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/a540605e Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/a540605e Branch: refs/heads/1.4-rc Commit: a540605e8a92a977a869e860a540049fb8767fc3 Parents: 1a79ef1 Author: shaofengshi <shaofeng...@apache.org> Authored: Wed Mar 2 17:12:10 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Wed Mar 2 17:15:07 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/source/hive/HiveSourceTableLoader.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/a540605e/source-hive/src/main/java/org/apache/kylin/source/hive/HiveSourceTableLoader.java ---------------------------------------------------------------------- diff --git a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveSourceTableLoader.java b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveSourceTableLoader.java index bc722b3..45271a9 100644 --- a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveSourceTableLoader.java +++ b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveSourceTableLoader.java @@ -117,7 +117,12 @@ public class HiveSourceTableLoader { FieldSchema field = fields.get(i); ColumnDesc cdesc = new ColumnDesc(); cdesc.setName(field.getName().toUpperCase()); - cdesc.setDatatype(field.getType()); + // use "double" in kylin for "float" + if ("float".equalsIgnoreCase(field.getType())) { + cdesc.setDatatype("double"); + } else { + cdesc.setDatatype(field.getType()); + } cdesc.setId(String.valueOf(i + 1)); columns.add(cdesc); }
