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 <liy...@apache.org> Authored: Tue Mar 29 14:36:01 2016 +0800 Committer: Li Yang <liy...@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);
