public TypeConverter get()

in jsonschema-kafkaconnect-converter/src/main/java/com/amazonaws/services/schemaregistry/kafkaconnect/jsonschema/typeconverters/TypeConverterFactory.java [46:73]

• 26 lines of code
• 10 McCabe index (conditional complexity)

    public TypeConverter get(@NonNull org.everit.json.schema.Schema jsonSchema,
                             String connectType) {
        TypeConverter typeConverter = null;

        if (jsonSchema instanceof BooleanSchema) {
            typeConverter = get(Schema.Type.BOOLEAN);
        } else if (jsonSchema instanceof NumberSchema) {
            typeConverter = get(Schema.Type.valueOf(connectType.toUpperCase()));
        } else if (jsonSchema instanceof StringSchema) {
            typeConverter = "bytes".equals(connectType) ? get(Schema.Type.BYTES) : get(Schema.Type.STRING);
        } else if (jsonSchema instanceof EnumSchema) {
            typeConverter = get(Schema.Type.STRING);
        } else if (jsonSchema instanceof ArraySchema) {
            if ("map".equals(connectType)) {
                typeConverter = get(Schema.Type.MAP);
            } else {
                typeConverter = get(Schema.Type.ARRAY);
            }
        } else if (jsonSchema instanceof ObjectSchema) {
            if ("map".equals(connectType)) {
                typeConverter = get(Schema.Type.MAP);
            } else {
                typeConverter = get(Schema.Type.STRUCT);
            }
        }

        return typeConverter;
    }