@Override
    public Row deserialize(byte[] message) throws IOException {
        return deserialize(message, true);
    }
@Test
    void testTimestampGenericGenericSerializeDeserializeNewMapping() throws Exception {
        final Tuple4<Class<? extends SpecificRecord>, SpecificRecord, GenericRecord, Row> testData =
                AvroTestUtils.getTimestampTestData();

        final String schemaString = testData.f2.getSchema().toString();

        final AvroRowSerializationSchema serializationSchema =
                new AvroRowSerializationSchema(schemaString);
        final AvroRowDeserializationSchema deserializationSchema =
                new AvroRowDeserializationSchema(schemaString);

        final byte[] bytes = serializationSchema.serialize(testData.f3);
        final Row actual = deserializationSchema.deserialize(bytes);
        assertThat(actual).isEqualTo(testData.f3);
    }