You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/12/29 07:44:40 UTC
kylin git commit: minor,
apply scan.setCaching() and scan.setMaxResultSize() on
HBaseResourceStore
Repository: kylin
Updated Branches:
refs/heads/2.0-rc a035cc27a -> 9095b3d60
minor, apply scan.setCaching() and scan.setMaxResultSize() on HBaseResourceStore
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/9095b3d6
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/9095b3d6
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/9095b3d6
Branch: refs/heads/2.0-rc
Commit: 9095b3d60d656fd25d37e4c472def4f7e2810b71
Parents: a035cc2
Author: Li, Yang <ya...@ebay.com>
Authored: Tue Dec 29 14:43:34 2015 +0800
Committer: Li, Yang <ya...@ebay.com>
Committed: Tue Dec 29 14:44:27 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/storage/hbase/HBaseResourceStore.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/9095b3d6/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java
index 511a7cf..b5b0378 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java
@@ -284,6 +284,9 @@ public class HBaseResourceStore extends ResourceStore {
byte[] endRow = plusZero(startRow);
Scan scan = new Scan(startRow, endRow);
+ scan.setCaching(1);
+ scan.setMaxResultSize(kylinConfig.getHBaseScanMaxResultSize());
+
if (!fetchContent && !fetchTimestamp) {
scan.setFilter(new KeyOnlyFilter());
} else {