Serialization of java.math.BigDecimal to Avro bytes or fixed type added.

Author: MichalFoksa

avro/src/main/java/com/fasterxml/jackson/dataformat/avro/ser/NonBSGenericDatumWriter.java

@@ -6,6 +6,7 @@
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
 
+import org.apache.avro.Conversions.DecimalConversion;
 import org.apache.avro.Schema;
 import org.apache.avro.Schema.Type;
 import org.apache.avro.generic.GenericData;
@@ -27,6 +28,8 @@ public class NonBSGenericDatumWriter<D>
     private final static Class<?> CLS_BIG_DECIMAL = BigDecimal.class;
     private final static Class<?> CLS_BIG_INTEGER = BigInteger.class;
 
+    private final static DecimalConversion BIG_DECIMAL_CONVERSION = new DecimalConversion();
+
     public NonBSGenericDatumWriter(Schema root) {
 	super(root);
     }
@@ -97,6 +100,11 @@ protected void write(Schema schema, Object datum, Encoder out) throws IOExceptio
                 super.writeWithoutConversion(schema, ByteBuffer.wrap((byte[]) datum), out);
                 return;
             }
+            if (datum.getClass() == CLS_BIG_DECIMAL) {
+                super.writeWithoutConversion(schema, BIG_DECIMAL_CONVERSION.toBytes(
+                        (BigDecimal) datum, schema, schema.getLogicalType()), out);
+                return;
+            }
             break;
         case FIXED:
             // One more mismatch to fix
@@ -111,6 +119,11 @@ protected void write(Schema schema, Object datum, Encoder out) throws IOExceptio
                 super.writeWithoutConversion(schema, new GenericData.Fixed(schema, (byte[]) datum), out);
                 return;
             }
+            if (datum.getClass() == CLS_BIG_DECIMAL) {
+                super.writeWithoutConversion(schema, BIG_DECIMAL_CONVERSION.toFixed(
+                        (BigDecimal) datum, schema, schema.getLogicalType()), out);
+                return;
+            }
             break;
 
         default: