You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by xx...@apache.org on 2020/05/30 10:25:56 UTC
[kylin] 09/11: KYLIN-4368 Global domain dict for MR/Hive global dict
This is an automated email from the ASF dual-hosted git repository.
xxyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git
commit 276f79ba914c62b705d48517747dde6e934f352c
Author: wangxiaojing <wa...@didichuxing.com>
AuthorDate: Wed May 6 15:22:58 2020 +0800
KYLIN-4368 Global domain dict for MR/Hive global dict
---
.../main/java/org/apache/kylin/common/KylinConfigBase.java | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
diff --git a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java
index 207d8ca..f7f73ac 100644
--- a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java
+++ b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java
@@ -661,13 +661,19 @@ public abstract class KylinConfigBase implements Serializable {
}
/**
- * MR/Hive global domain dic (reuse dict from other global dic column)
+ * MR/Hive global domain dic (reuse dict from other cube's MR/Hive global dic column)
* @return
*/
public Map<String, String> getMrHiveDictRefColumns() {
Map<String, String> result = new HashMap<>();
-
- //toDo Implementation of Mr/Hive global domain dict config
+ String columnStr = getOptional("kylin.dictionary.mr-hive.ref.columns", "");
+ if (!StringUtils.isEmpty(columnStr)) {
+ String[] pairs = columnStr.split(",");
+ for (String pair : pairs) {
+ String [] infos = pair.split(":");
+ result.put(infos[0], infos[1]);
+ }
+ }
return result;
}