You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/02/12 06:43:36 UTC
[46/50] incubator-kylin git commit: KYLIN-608 bug fix
KYLIN-608 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/a864ba2d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/a864ba2d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/a864ba2d
Branch: refs/heads/inverted-index
Commit: a864ba2d2c3e7354dac0f66e7c315563a0e71b88
Parents: ecfc3cc
Author: honma <ho...@ebay.com>
Authored: Thu Feb 12 13:02:57 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Thu Feb 12 13:02:57 2015 +0800
----------------------------------------------------------------------
.../coprocessor/endpoint/EndpointAggregators.java | 15 ++++++++-------
1 file changed, 8 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/a864ba2d/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/EndpointAggregators.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/EndpointAggregators.java b/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/EndpointAggregators.java
index c6d8c49..516c160 100644
--- a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/EndpointAggregators.java
+++ b/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/EndpointAggregators.java
@@ -157,6 +157,14 @@ public class EndpointAggregators {
rawTableRecord.setBytes(row, 0, row.length);
for (int metricIndex = 0; metricIndex < metricInfos.length; ++metricIndex) {
+ if (metricInfos[metricIndex].type == MetricType.Count) {
+ measureAggrs[metricIndex].aggregate(ONE);
+ continue;
+ }
+
+ if (metricInfos[metricIndex].type == MetricType.DimensionAsMetric) {
+ continue;
+ }
MetricInfo metricInfo = metricInfos[metricIndex];
MeasureAggregator aggregator = measureAggrs[metricIndex];
@@ -178,13 +186,6 @@ public class EndpointAggregators {
aggregator.aggregate(hllc);
}
}
-
- //aggregate for "count"
- for (int i = 0; i < metricInfos.length; ++i) {
- if (metricInfos[i].type == MetricType.Count) {
- measureAggrs[i].aggregate(ONE);
- }
- }
}
/**