commit 381e6a91e3b5ca4c1de96264537ea670ccb7af6f
author edi_bice <edi_bice@yahoo.com> Wed Feb 17 10:45:07 2016 -0500
committer Gianmarco De Francisci Morales <gdfm@apache.org> Tue Apr 19 11:33:42 2016 +0300
tree 609242d04d9a5fe5c5fc1e03779325f6aed22ff8
parent 0640831c53006f61776110a53a4a7e4f14bcabe2

SAMOA-58: Only add fields of supported types (double, float, long, int and enum) rather than adding and defaulting all non-enum to numeric and failing at value parse time

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 0547a5c..e7f18b5 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
@@ -254,7 +254,10 @@
         List<String> attributeLabels = attributeSchema.getEnumSymbols();
         attributes.add(new Attribute(field.name(), attributeLabels));
       }
-      else
+      else if (attributeSchema.getType() == Schema.Type.DOUBLE
+              || attributeSchema.getType() == Schema.Type.FLOAT
+              || attributeSchema.getType() == Schema.Type.LONG
+              || attributeSchema.getType() == Schema.Type.INT)
         attributes.add(new Attribute(field.name()));
     }
     return new InstanceInformation(relation, attributes);