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 <[email protected]> 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; }
