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 2018/07/01 14:12:31 UTC

[kylin] branch master updated: KYLIN-3384 Allow setting REPLICATION_SCOPE on newly created tables

This is an automated email from the ASF dual-hosted git repository.

shaofengshi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/master by this push:
     new 2c08e7f  KYLIN-3384 Allow setting REPLICATION_SCOPE on newly created tables
2c08e7f is described below

commit 2c08e7f1bd6d341a19d9ae9e2b9ab2afaefed4de
Author: GinaZhai <na...@kyligence.io>
AuthorDate: Fri Jun 29 09:36:49 2018 +0800

    KYLIN-3384 Allow setting REPLICATION_SCOPE on newly created tables
    
    Signed-off-by: shaofengshi <sh...@apache.org>
---
 .../src/main/java/org/apache/kylin/common/KylinConfigBase.java        | 4 ++++
 .../java/org/apache/kylin/storage/hbase/steps/CubeHTableUtil.java     | 1 +
 2 files changed, 5 insertions(+)

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 da56f92..3ae6c2d 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
@@ -1061,6 +1061,10 @@ abstract public class KylinConfigBase implements Serializable {
         return Long.parseLong(getOptional("kylin.storage.hbase.hconnection-threads-alive-seconds", "60"));
     }
 
+    public int getHBaseReplicationScope() {
+        return Integer.parseInt(getOptional("kylin.storage.hbase.replication-scope", "0"));
+    }
+
     // ============================================================================
     // ENGINE.MR
     // ============================================================================
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CubeHTableUtil.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CubeHTableUtil.java
index feb4842..f006adb 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CubeHTableUtil.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/CubeHTableUtil.java
@@ -202,6 +202,7 @@ public class CubeHTableUtil {
 
         cf.setInMemory(false);
         cf.setBloomFilterType(BloomType.NONE);
+        cf.setScope(kylinConfig.getHBaseReplicationScope());
         return cf;
     }