public TypeConverter get()

in jsonschema-kafkaconnect-converter/src/main/java/com/amazonaws/services/schemaregistry/kafkaconnect/jsonschema/typeconverters/TypeConverterFactory.java [95:149]
43 lines of code
13 McCabe index (conditional complexity)

    public TypeConverter get(@NonNull Schema.Type connectType) {
        switch (connectType) {
            case INT8:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new Int8TypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case INT16:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new Int16TypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case INT32:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new Int32TypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case INT64:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new Int64TypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case FLOAT32:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new Float32TypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case FLOAT64:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new Float64TypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case BOOLEAN:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new BooleanTypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case BYTES:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new BytesTypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case STRING:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new StringTypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case ARRAY:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new ArrayTypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case MAP:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new MapTypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            case STRUCT:
                this.typeConverterMap.computeIfAbsent(connectType.getName(), key -> new StructTypeConverter());

                return this.typeConverterMap.get(connectType.getName());
            default:
                String message = String.format("Unsupported connect type: %s", connectType.getName());
                throw new DataException(message);
        }
    }