You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/09/29 05:13:24 UTC

[2/2] incubator-kylin git commit: back to hbaseendpointscanner

back to hbaseendpointscanner


Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/10f0905b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/10f0905b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/10f0905b

Branch: refs/heads/KYLIN-942
Commit: 10f0905b4fd1286b296fdcd06f6677fe581a4afd
Parents: 62b536b
Author: honma <ho...@ebay.com>
Authored: Tue Sep 29 11:16:08 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Tue Sep 29 11:16:25 2015 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/storage/hbase/cube/v2/CubeScanner.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/10f0905b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeScanner.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeScanner.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeScanner.java
index a04c562..16d3415 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeScanner.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/CubeScanner.java
@@ -171,7 +171,7 @@ public class CubeScanner implements IGTScanner {
                             return false;
 
                         try {
-                            CubeHBaseRPC rpc = new CubeHBaseScanRPC(cubeSeg, cuboid, info);
+                            CubeHBaseRPC rpc = new CubeHBaseEndpointRPC(cubeSeg, cuboid, info);
                             inputScanners[cur] = rpc.getGTScanner(scanRequests.get(cur));
                             curIterator = inputScanners[cur].iterator();
                         } catch (IOException e) {