use more space for top-n aggregator Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/fc14ef77 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/fc14ef77 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/fc14ef77
Branch: refs/heads/1.5.x-HBase1.1.3 Commit: fc14ef77a41b525ea708b0c415be55bc80dc6417 Parents: 34c6ece Author: shaofengshi <shaofeng...@apache.org> Authored: Fri Apr 1 17:50:54 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Fri Apr 1 17:51:05 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/measure/topn/TopNAggregator.java | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/fc14ef77/core-metadata/src/main/java/org/apache/kylin/measure/topn/TopNAggregator.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/measure/topn/TopNAggregator.java b/core-metadata/src/main/java/org/apache/kylin/measure/topn/TopNAggregator.java index 6ea4e7a..ef997eb 100644 --- a/core-metadata/src/main/java/org/apache/kylin/measure/topn/TopNAggregator.java +++ b/core-metadata/src/main/java/org/apache/kylin/measure/topn/TopNAggregator.java @@ -18,13 +18,9 @@ package org.apache.kylin.measure.topn; -import java.util.Map; - import org.apache.kylin.common.util.ByteArray; import org.apache.kylin.measure.MeasureAggregator; -import com.google.common.collect.Maps; - /** * */ @@ -33,7 +29,6 @@ public class TopNAggregator extends MeasureAggregator<TopNCounter<ByteArray>> { int capacity = 0; TopNCounter<ByteArray> sum = null; - Map<ByteArray, Double> sanityCheckMap; @Override public void reset() { @@ -44,16 +39,14 @@ public class TopNAggregator extends MeasureAggregator<TopNCounter<ByteArray>> { public void aggregate(TopNCounter<ByteArray> value) { if (sum == null) { capacity = value.getCapacity(); - sum = new TopNCounter<>(capacity); - sanityCheckMap = Maps.newHashMap(); + sum = new TopNCounter<>(capacity * 10); } sum.merge(value); } @Override public TopNCounter<ByteArray> getState() { - - //sum.retain(capacity); + sum.retain(capacity); return sum; }
