summaryrefslogtreecommitdiff
path: root/core/src/main/java/org/elasticsearch/search/aggregations/metrics
diff options
context:
space:
mode:
authorChristoph Büscher <christoph@elastic.co>2017-04-27 11:04:57 +0200
committerGitHub <noreply@github.com>2017-04-27 11:04:57 +0200
commit93415cdfb42f5ecfc40e1bf8a9ecc5369f480b65 (patch)
treec17d39d53777a0e106f6943f1d7c850bacdace8b /core/src/main/java/org/elasticsearch/search/aggregations/metrics
parentb46c39ea2e82bf917a4605c3105623a63532fcbe (diff)
Add parsing for InternalPercentilesBucket (#24330)
Diffstat (limited to 'core/src/main/java/org/elasticsearch/search/aggregations/metrics')
-rw-r--r--core/src/main/java/org/elasticsearch/search/aggregations/metrics/percentiles/ParsedPercentiles.java9
1 files changed, 6 insertions, 3 deletions
diff --git a/core/src/main/java/org/elasticsearch/search/aggregations/metrics/percentiles/ParsedPercentiles.java b/core/src/main/java/org/elasticsearch/search/aggregations/metrics/percentiles/ParsedPercentiles.java
index eee058fc2f..a96fb2cd13 100644
--- a/core/src/main/java/org/elasticsearch/search/aggregations/metrics/percentiles/ParsedPercentiles.java
+++ b/core/src/main/java/org/elasticsearch/search/aggregations/metrics/percentiles/ParsedPercentiles.java
@@ -33,8 +33,8 @@ import java.util.Map;
public abstract class ParsedPercentiles extends ParsedAggregation implements Iterable<Percentile> {
- private final Map<Double, Double> percentiles = new LinkedHashMap<>();
- private final Map<Double, String> percentilesAsString = new HashMap<>();
+ protected final Map<Double, Double> percentiles = new LinkedHashMap<>();
+ protected final Map<Double, String> percentilesAsString = new HashMap<>();
private boolean keyed;
@@ -130,7 +130,6 @@ public abstract class ParsedPercentiles extends ParsedAggregation implements Ite
if (token.isValue()) {
if (token == XContentParser.Token.VALUE_NUMBER) {
aggregation.addPercentile(Double.valueOf(parser.currentName()), parser.doubleValue());
-
} else if (token == XContentParser.Token.VALUE_STRING) {
int i = parser.currentName().indexOf("_as_string");
if (i > 0) {
@@ -140,6 +139,8 @@ public abstract class ParsedPercentiles extends ParsedAggregation implements Ite
aggregation.addPercentile(Double.valueOf(parser.currentName()), Double.valueOf(parser.text()));
}
}
+ } else if (token == XContentParser.Token.VALUE_NULL) {
+ aggregation.addPercentile(Double.valueOf(parser.currentName()), Double.NaN);
}
}
} else if (token == XContentParser.Token.START_ARRAY) {
@@ -162,6 +163,8 @@ public abstract class ParsedPercentiles extends ParsedAggregation implements Ite
} else if (CommonFields.VALUE_AS_STRING.getPreferredName().equals(currentFieldName)) {
valueAsString = parser.text();
}
+ } else if (token == XContentParser.Token.VALUE_NULL) {
+ value = Double.NaN;
}
}
if (key != null) {