public Object toAvro()

in src/main/java/com/epam/eco/commons/avro/converter/DefaultAvroConverters.java [345:363]

• 14 lines of code
• 2 McCabe index (conditional complexity)

        public Object toAvro(Object value, Schema schema, AvroConverters converters) {
            if (value instanceof Map) {
                Schema mapValuesSchema = schema.getValueType();
                
                Map<String, Object> convertedMap = new HashMap<>();
                
                BiConsumer<String, Object> enrichMap = (k, v) -> convertedMap.put(
                    k,
                    converters.getForSchema(mapValuesSchema).
                        toAvro(v, mapValuesSchema, converters)
                );
                
                ((Map<String, Object>) value).forEach(enrichMap);
                
                return convertedMap;
            }

            throw new AvroConversionException(value, schema);
        }