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/10/28 08:07:31 UTC

incubator-kylin git commit: bug fix

Repository: incubator-kylin
Updated Branches:
  refs/heads/KYLIN-942-x 342ee79e0 -> 7e1f084e2


bug fix


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

Branch: refs/heads/KYLIN-942-x
Commit: 7e1f084e2f6d2c0fa988fe7032f3b4dc7b3c9f85
Parents: 342ee79
Author: honma <ho...@ebay.com>
Authored: Wed Oct 28 15:11:54 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Wed Oct 28 15:11:54 2015 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/gridtable/GTScanRange.java | 15 +++++----------
 1 file changed, 5 insertions(+), 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/7e1f084e/core-cube/src/main/java/org/apache/kylin/gridtable/GTScanRange.java
----------------------------------------------------------------------
diff --git a/core-cube/src/main/java/org/apache/kylin/gridtable/GTScanRange.java b/core-cube/src/main/java/org/apache/kylin/gridtable/GTScanRange.java
index d5fa6c0..87f51df 100644
--- a/core-cube/src/main/java/org/apache/kylin/gridtable/GTScanRange.java
+++ b/core-cube/src/main/java/org/apache/kylin/gridtable/GTScanRange.java
@@ -3,9 +3,6 @@ package org.apache.kylin.gridtable;
 import java.util.Collections;
 import java.util.List;
 
-import javax.annotation.Nullable;
-
-import com.google.common.base.Function;
 import com.google.common.collect.Lists;
 
 public class GTScanRange {
@@ -28,15 +25,13 @@ public class GTScanRange {
     }
 
     public GTScanRange replaceGTInfo(final GTInfo gtInfo) {
+        List<GTRecord> newFuzzyKeys = Lists.newArrayList();
+        for (GTRecord input : fuzzyKeys) {
+            newFuzzyKeys.add(new GTRecord(gtInfo, input.maskForEqualHashComp(), input.cols));
+        }
         return new GTScanRange(new GTRecord(gtInfo, pkStart.maskForEqualHashComp(), pkStart.cols), //
                 new GTRecord(gtInfo, pkEnd.maskForEqualHashComp(), pkEnd.cols), //
-                Lists.transform(fuzzyKeys, new Function<GTRecord, GTRecord>() {
-                    @Nullable
-                    @Override
-                    public GTRecord apply(GTRecord input) {
-                        return new GTRecord(gtInfo, input.maskForEqualHashComp(), input.cols);
-                    }
-                }));
+                newFuzzyKeys);
     }
 
     @Override