You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/01/31 13:01:56 UTC
[29/50] incubator-kylin git commit: allow same name tables from
different schema
allow same name tables from different schema
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/bd1efca4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/bd1efca4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/bd1efca4
Branch: refs/heads/inverted-index
Commit: bd1efca419f3037578f221ba80479e7937fd37a0
Parents: 5472d9e
Author: Li, Yang <ya...@ebay.com>
Authored: Wed Jan 28 18:46:25 2015 +0800
Committer: Li, Yang <ya...@ebay.com>
Committed: Wed Jan 28 18:46:25 2015 +0800
----------------------------------------------------------------------
.../metadata/tool/HiveSourceTableLoader.java | 22 ++++----------------
1 file changed, 4 insertions(+), 18 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/bd1efca4/metadata/src/main/java/com/kylinolap/metadata/tool/HiveSourceTableLoader.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/com/kylinolap/metadata/tool/HiveSourceTableLoader.java b/metadata/src/main/java/com/kylinolap/metadata/tool/HiveSourceTableLoader.java
index ad01dff..3642fda 100644
--- a/metadata/src/main/java/com/kylinolap/metadata/tool/HiveSourceTableLoader.java
+++ b/metadata/src/main/java/com/kylinolap/metadata/tool/HiveSourceTableLoader.java
@@ -58,27 +58,13 @@ public class HiveSourceTableLoader {
Map<String, Set<String>> db2tables = Maps.newHashMap();
for (String table : hiveTables) {
- String[] dbtableNames = HadoopUtil.parseHiveTableName(table);
- Set<String> set = db2tables.get(dbtableNames[0]);
+ String[] parts = HadoopUtil.parseHiveTableName(table);
+ Set<String> set = db2tables.get(parts[0]);
if (set == null) {
set = Sets.newHashSet();
- db2tables.put(dbtableNames[0], set);
- }
- set.add(dbtableNames[1]);
- }
-
- for (String database : db2tables.keySet()) {
- for (String table : db2tables.get(database)) {
- TableDesc tableDesc = MetadataManager.getInstance(config).getTableDesc(table);
- if (tableDesc == null) {
- continue;
- }
- if (tableDesc.getDatabase().equalsIgnoreCase(database)) {
- continue;
- } else {
- throw new UnsupportedOperationException(String.format("there is already a table[%s] in database[%s]", tableDesc.getName(), tableDesc.getDatabase()));
- }
+ db2tables.put(parts[0], set);
}
+ set.add(parts[1]);
}
// extract from hive