public Schema getFieldSchema()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java [264:277]

• 11 lines of code
• 4 McCabe index (conditional complexity)

    public Schema getFieldSchema(DataType type) {
        if (type.isPrimitive()) {
            return getPrimitiveTypeSchema(type);

        } else if (type instanceof ArrayDataType) {
            return getArraySchema((ArrayDataType) type);

        } else if (type instanceof ClassDataType) {
            return getObjectSchema((ClassDataType) type);

        } else {
            throw new IllegalArgumentException("Unrecognized dataType: " + type);
        }
    }