You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2015/05/15 05:06:14 UTC
[02/50] [abbrv] incubator-kylin git commit: KYLIN-748 refine
SqlHiveDataTypeMapping
KYLIN-748 refine SqlHiveDataTypeMapping
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/b376b60c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/b376b60c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/b376b60c
Branch: refs/heads/streaming-localdict
Commit: b376b60cb831716c4760e8a69651a8d1c6a845b4
Parents: 142fb37
Author: honma <ho...@ebay.com>
Authored: Mon May 4 18:12:28 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Mon May 4 18:12:28 2015 +0800
----------------------------------------------------------------------
.../job/hadoop/hive/SqlHiveDataTypeMapping.java | 17 +----------------
1 file changed, 1 insertion(+), 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/b376b60c/job/src/main/java/org/apache/kylin/job/hadoop/hive/SqlHiveDataTypeMapping.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/hive/SqlHiveDataTypeMapping.java b/job/src/main/java/org/apache/kylin/job/hadoop/hive/SqlHiveDataTypeMapping.java
index f283501..0aec98f 100644
--- a/job/src/main/java/org/apache/kylin/job/hadoop/hive/SqlHiveDataTypeMapping.java
+++ b/job/src/main/java/org/apache/kylin/job/hadoop/hive/SqlHiveDataTypeMapping.java
@@ -18,29 +18,14 @@
package org.apache.kylin.job.hadoop.hive;
-import java.util.HashMap;
-import java.util.Map;
-
/**
* @author George Song (ysong1)
*
*/
public class SqlHiveDataTypeMapping {
- private static final Map<String, String> sqlToHiveDataTypeMapping = new HashMap<String, String>();
-
- static {
- sqlToHiveDataTypeMapping.put("short", "smallint");
- sqlToHiveDataTypeMapping.put("long", "bigint");
- sqlToHiveDataTypeMapping.put("byte", "tinyint");
- sqlToHiveDataTypeMapping.put("datetime", "date");
- }
-
public static String getHiveDataType(String javaDataType) {
- String hiveDataType = sqlToHiveDataTypeMapping.get(javaDataType.toLowerCase());
- if (hiveDataType == null) {
- hiveDataType = javaDataType;
- }
+ String hiveDataType = javaDataType.toLowerCase().startsWith("varchar") ? "string" : javaDataType;
return hiveDataType.toLowerCase();
}
}