commit 15df2523193a2130d077f0afc1b53e7c596231e1
author edi_bice <edi_bice@yahoo.com> Tue Feb 23 13:59:33 2016 -0500
committer Gianmarco De Francisci Morales <gdfm@apache.org> Tue Apr 19 11:33:42 2016 +0300
tree 77b01fd387c8830691532262d2703b0e81bbf73d
parent 78ae8fce13927afd4ec04d1f83e7a500009520e2

SAMOA-58: Filter out NaN and Inf values

samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java

diff --git a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
index 9f0664c..8c49537 100644
--- a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
+++ b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
@@ -26,6 +26,7 @@
 
 import org.apache.avro.Schema;
 import org.apache.avro.Schema.Field;
+import org.apache.avro.SchemaBuilder;
 import org.apache.avro.generic.GenericData.EnumSymbol;
 import org.apache.avro.generic.GenericRecord;
 import org.apache.avro.io.DatumReader;
@@ -164,8 +165,10 @@
 
       if (isNumeric)
       {
-        if (value instanceof Double)
-          this.setSparseValue(instance, indexValues, attributeValues, numAttribute, (double) value);
+        if (value instanceof Double) {
+          Double v = (double) value;
+          if (Double.isFinite(v)) this.setSparseValue(instance, indexValues, attributeValues, numAttribute, (double) value);
+        }
         else if (value instanceof Long)
           this.setSparseValue(instance, indexValues, attributeValues, numAttribute, (long) value);
         else if (value instanceof Integer)