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 <mahong...@apache.org> Authored: Thu Jul 28 11:39:09 2016 +0800 Committer: Hongbin Ma <mahong...@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(); }
