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 2016/07/28 03:39:30 UTC
kylin git commit: minor, add more logs
Repository: kylin
Updated Branches:
refs/heads/beforepomupdate a44ada795 -> 97e67f0de
minor, add more logs
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/97e67f0d
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/97e67f0d
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/97e67f0d
Branch: refs/heads/beforepomupdate
Commit: 97e67f0de44e614c7fb1ea44edd230ed2525e2f4
Parents: a44ada7
Author: Hongbin Ma <ma...@apache.org>
Authored: Thu Jul 28 11:39:09 2016 +0800
Committer: Hongbin Ma <ma...@apache.org>
Committed: Thu Jul 28 11:39:09 2016 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/gridtable/GTAggregateScanner.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/97e67f0d/core-cube/src/main/java/org/apache/kylin/gridtable/GTAggregateScanner.java
----------------------------------------------------------------------
diff --git a/core-cube/src/main/java/org/apache/kylin/gridtable/GTAggregateScanner.java b/core-cube/src/main/java/org/apache/kylin/gridtable/GTAggregateScanner.java
index 2a83d03..cb23af4 100644
--- a/core-cube/src/main/java/org/apache/kylin/gridtable/GTAggregateScanner.java
+++ b/core-cube/src/main/java/org/apache/kylin/gridtable/GTAggregateScanner.java
@@ -30,16 +30,16 @@ import java.util.Arrays;
import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
-import java.util.Map.Entry;
import java.util.PriorityQueue;
import java.util.SortedMap;
+import java.util.Map.Entry;
import org.apache.commons.io.IOUtils;
import org.apache.kylin.common.util.ByteArray;
import org.apache.kylin.common.util.ImmutableBitSet;
import org.apache.kylin.common.util.MemoryBudgetController;
-import org.apache.kylin.common.util.MemoryBudgetController.MemoryWaterLevel;
import org.apache.kylin.common.util.Pair;
+import org.apache.kylin.common.util.MemoryBudgetController.MemoryWaterLevel;
import org.apache.kylin.measure.BufferedMeasureEncoder;
import org.apache.kylin.measure.MeasureAggregator;
import org.apache.kylin.measure.MeasureAggregators;
@@ -131,9 +131,12 @@ public class GTAggregateScanner implements IGTScanner {
@Override
public Iterator<GTRecord> iterator() {
+ long count = 0;
for (GTRecord r : inputScanner) {
+ count++;
aggrCache.aggregate(r);
}
+ logger.info("GTAggregateScanner input rows: " + count);
return aggrCache.iterator();
}