Added testcase for schema evolution check

test/unit/voldemort/serialization/avro/versioned/AvroBackwardsCompatibilityTest.java

@@ -34,6 +34,19 @@ private static Object readVersion0(Map<Integer, String> versions, byte[] version
 
     }
 
+    private static byte[] writeVersion0with1Present(Map<Integer, String> versions, Schema s0) {
+
+        GenericData.Record record = new GenericData.Record(s0);
+        record.put("original", new Utf8("Abhinay"));
+        AvroVersionedGenericSerializer serializer = new AvroVersionedGenericSerializer(versions);
+        return serializer.toBytes(record);
+
+    }
+
+    /*
+     * This tests if a client tries to deserialize an object created using an
+     * old schema is successful or not
+     */
     @Test
     public void testAvroSchemaEvolution() throws IOException {
 
@@ -55,4 +68,28 @@ public void testAvroSchemaEvolution() throws IOException {
         GenericData.Record record = (Record) readVersion0(versions, versionZeroBytes);
 
     }
+
+    /*
+     * This tests if a client tries to serialize an object created using an old
+     * schema is successful or not
+     */
+    @Test
+    public void testAvroSchemaEvolutionWrite() throws IOException {
+
+        String versionZero = "{\"type\": \"record\", \"name\": \"myrec\",\"fields\": [{ \"name\": \"original\", \"type\": \"string\" }]}";
+
+        String versionOne = "{\"type\": \"record\", \"name\": \"myrec\",\"fields\": [{ \"name\": \"original\", \"type\": \"string\" } ,"
+                            + "{ \"name\": \"new-field\", \"type\": \"string\", \"default\":\"\" }]}";
+
+        Schema s0 = Schema.parse(versionZero);
+        Schema s1 = Schema.parse(versionOne);
+
+        Map<Integer, String> versions = new HashMap<Integer, String>();
+
+        versions.put(0, versionZero);
+        versions.put(1, versionOne);
+
+        byte[] versionZeroBytes = writeVersion0with1Present(versions, s0);
+
+    }
 }