summaryrefslogtreecommitdiff
path: root/core/src/main/java/org/elasticsearch/search/aggregations/bucket/range/RangeAggregator.java
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/main/java/org/elasticsearch/search/aggregations/bucket/range/RangeAggregator.java')
-rw-r--r--core/src/main/java/org/elasticsearch/search/aggregations/bucket/range/RangeAggregator.java11
1 files changed, 6 insertions, 5 deletions
diff --git a/core/src/main/java/org/elasticsearch/search/aggregations/bucket/range/RangeAggregator.java b/core/src/main/java/org/elasticsearch/search/aggregations/bucket/range/RangeAggregator.java
index a2e55c18fb..4512803075 100644
--- a/core/src/main/java/org/elasticsearch/search/aggregations/bucket/range/RangeAggregator.java
+++ b/core/src/main/java/org/elasticsearch/search/aggregations/bucket/range/RangeAggregator.java
@@ -236,11 +236,12 @@ public class RangeAggregator extends BucketsAggregator {
return new LeafBucketCollectorBase(sub, values) {
@Override
public void collect(int doc, long bucket) throws IOException {
- values.setDocument(doc);
- final int valuesCount = values.count();
- for (int i = 0, lo = 0; i < valuesCount; ++i) {
- final double value = values.valueAt(i);
- lo = collect(doc, value, bucket, lo);
+ if (values.advanceExact(doc)) {
+ final int valuesCount = values.docValueCount();
+ for (int i = 0, lo = 0; i < valuesCount; ++i) {
+ final double value = values.nextValue();
+ lo = collect(doc, value, bucket, lo);
+ }
}
}