kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liy...@apache.org
Subject [2/2] kylin git commit: KYLIN-1543 Minor refactor
Date Tue, 29 Mar 2016 10:35:46 GMT
KYLIN-1543 Minor refactor


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

Branch: refs/heads/master
Commit: 6e2afbb98d7670dc67ca7c6d38a3e199523da3ff
Parents: be30f4b
Author: Li Yang <liyang@apache.org>
Authored: Tue Mar 29 14:36:01 2016 +0800
Committer: Li Yang <liyang@apache.org>
Committed: Tue Mar 29 18:35:03 2016 +0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/kylin/gridtable/GTFilterScanner.java  | 2 +-
 .../org/apache/kylin/storage/hbase/cube/v2/HBaseReadonlyStore.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/6e2afbb9/core-cube/src/main/java/org/apache/kylin/gridtable/GTFilterScanner.java
----------------------------------------------------------------------
diff --git a/core-cube/src/main/java/org/apache/kylin/gridtable/GTFilterScanner.java b/core-cube/src/main/java/org/apache/kylin/gridtable/GTFilterScanner.java
index 59f1df7..8017ca0 100644
--- a/core-cube/src/main/java/org/apache/kylin/gridtable/GTFilterScanner.java
+++ b/core-cube/src/main/java/org/apache/kylin/gridtable/GTFilterScanner.java
@@ -70,13 +70,13 @@ public class GTFilterScanner implements IGTScanner {
         return new Iterator<GTRecord>() {
 
             private Iterator<GTRecord> inputIterator = inputScanner.iterator();
+            private IFilterCodeSystem<ByteArray> filterCodeSystem = GTUtil.wrap(getInfo().codeSystem.getComparator());
 
             @Override
             public boolean hasNext() {
                 if (next != null)
                     return true;
 
-                IFilterCodeSystem<ByteArray> filterCodeSystem = GTUtil.wrap(getInfo().codeSystem.getComparator());
 
                 while (inputIterator.hasNext()) {
                     next = inputIterator.next();

http://git-wip-us.apache.org/repos/asf/kylin/blob/6e2afbb9/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/HBaseReadonlyStore.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/HBaseReadonlyStore.java
b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/HBaseReadonlyStore.java
index ff7498b..850b3d9 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/HBaseReadonlyStore.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/HBaseReadonlyStore.java
@@ -114,7 +114,7 @@ public class HBaseReadonlyStore implements IGTStore {
                         // metrics
                         for (int i = 0; i < hbaseColumns.size(); i++) {
                             Pair<byte[], byte[]> hbaseColumn = hbaseColumns.get(i);
-                            Cell cell = HBaseReadonlyStore.findCell(oneRow, hbaseColumn.getFirst(),
hbaseColumn.getSecond());
+                            Cell cell = findCell(oneRow, hbaseColumn.getFirst(), hbaseColumn.getSecond());
                             Preconditions.checkNotNull(cell);
                             buf = byteBuffer(cell.getValueArray(), cell.getValueOffset(),
cell.getValueLength());
                             oneRecord.loadColumns(hbaseColumnsToGT.get(i), buf);


Mime
View raw message