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 <[email protected]>
AuthorDate: Fri Jun 29 09:36:49 2018 +0800
KYLIN-3384 Allow setting REPLICATION_SCOPE on newly created tables
Signed-off-by: shaofengshi <[email protected]>
---
.../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;
}