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.z...@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 <shaofeng...@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; }