Repository: kylin Updated Branches: refs/heads/master 4018e6671 -> ba7254a34
KYLIN-1719 Add config in scan request to control compress the query result or not Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/7d973779 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/7d973779 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/7d973779 Branch: refs/heads/master Commit: 7d9737796374b1542467798d8ccf99eda17d5610 Parents: 4018e66 Author: sunyerui <sunye...@gmail.com> Authored: Wed Jun 1 22:42:39 2016 +0800 Committer: Yang Li <liy...@apache.org> Committed: Sun Jun 5 08:24:37 2016 +0800 ---------------------------------------------------------------------- .../apache/kylin/cube/model/validation/rule/DictionaryRule.java | 1 + .../apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/7d973779/core-cube/src/main/java/org/apache/kylin/cube/model/validation/rule/DictionaryRule.java ---------------------------------------------------------------------- diff --git a/core-cube/src/main/java/org/apache/kylin/cube/model/validation/rule/DictionaryRule.java b/core-cube/src/main/java/org/apache/kylin/cube/model/validation/rule/DictionaryRule.java new file mode 100644 index 0000000..7ce263d --- /dev/null +++ b/core-cube/src/main/java/org/apache/kylin/cube/model/validation/rule/DictionaryRule.java @@ -0,0 +1 @@ +package org.apache.kylin.cube.model.validation.rule; /** * Created by sunyerui on 16/6/1. */ public class DictionaryRule { } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/kylin/blob/7d973779/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java index 0c6a053..e81df61 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeHBaseEndpointRPC.java @@ -321,7 +321,7 @@ public class CubeHBaseEndpointRPC extends CubeHBaseRPC { final AtomicInteger totalScannedCount = new AtomicInteger(0); final ExpectedSizeIterator epResultItr = new ExpectedSizeIterator(shardNum); - final boolean compressionResult = cubeSeg.getCubeDesc().getConfig().getCompressionResult(); + final boolean compressionResult = KylinConfig.getInstanceFromEnv().getCompressionResult(); final CubeVisitProtos.CubeVisitRequest.Builder builder = CubeVisitProtos.CubeVisitRequest.newBuilder(); builder.setGtScanRequest(scanRequestByteString).setHbaseRawScan(rawScanByteString); for (IntList intList : hbaseColumnsToGTIntList) {
