You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by nj...@apache.org on 2016/04/18 08:35:18 UTC
[36/50] kylin git commit: change ‘float’ to ‘double’ when sync a hive table into kylin
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 <sh...@apache.org>
Authored: Wed Mar 2 17:12:10 2016 +0800
Committer: shaofengshi <sh...@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);
}