Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #498 from metamx/fix-nan-serde 

handle NaN / Infinity values
This commit is contained in:
fjy 2014-04-22 12:17:29 -06:00
parent 4e1c159ff1 3bac366013
commit 44fec509dd
4 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
processing/src/main/java/io/druid/query/aggregation/DoubleSumAggregatorFactory.java
View File

@ -88,6 +88,10 @@ public class DoubleSumAggregatorFactory implements AggregatorFactory
@Override @Override
public Object deserialize(Object object) public Object deserialize(Object object)
{ {
// handle "NaN" / "Infinity" values serialized as strings in JSON
if (object instanceof String) {
return Double.parseDouble((String) object);
}
return object; return object;
} }

4
processing/src/main/java/io/druid/query/aggregation/JavaScriptAggregatorFactory.java
View File

@ -139,6 +139,10 @@ public class JavaScriptAggregatorFactory implements AggregatorFactory
@Override @Override
public Object deserialize(Object object) public Object deserialize(Object object)
{ {
// handle "NaN" / "Infinity" values serialized as strings in JSON
if (object instanceof String) {
return Double.parseDouble((String) object);
}
return object; return object;
} }

1
processing/src/main/java/io/druid/query/aggregation/MaxAggregatorFactory.java
View File

@ -85,6 +85,7 @@ public class MaxAggregatorFactory implements AggregatorFactory
@Override @Override
public Object deserialize(Object object) public Object deserialize(Object object)
{ {
// handle "NaN" / "Infinity" values serialized as strings in JSON
if (object instanceof String) { if (object instanceof String) {
return Double.parseDouble((String) object); return Double.parseDouble((String) object);
} }

1
processing/src/main/java/io/druid/query/aggregation/MinAggregatorFactory.java
View File

@ -85,6 +85,7 @@ public class MinAggregatorFactory implements AggregatorFactory
@Override @Override
public Object deserialize(Object object) public Object deserialize(Object object)
{ {
// handle "NaN" / "Infinity" values serialized as strings in JSON
if (object instanceof String) { if (object instanceof String) {
return Double.parseDouble((String) object); return Double.parseDouble((String) object);
} }