public static ValueType getTypeIndex()

in src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java [86:130]

• 45 lines of code
• 21 McCabe index (conditional complexity)

    public static ValueType getTypeIndex(Class<?> clazz) {
        if (byte[].class.equals(clazz)) {
            return ValueType.V_ByteArray;
        } else if (String.class.equals(clazz)) {
            return ValueType.V_String;
        } else if (Byte.class.equals(clazz)) {
            return ValueType.V_Byte;
        } else if (Short.class.equals(clazz)) {
            return ValueType.V_Short;
        } else if (Integer.class.equals(clazz)) {
            return ValueType.V_Integer;
        } else if (Long.class.equals(clazz)) {
            return ValueType.V_Long;
        } else if (Float.class.equals(clazz)) {
            return ValueType.V_Float;
        } else if (Double.class.equals(clazz)) {
            return ValueType.V_Double;
        } else if (Boolean.class.equals(clazz)) {
            return ValueType.V_Boolean;
        } else if (Timestamp.class.equals(clazz)) {
            return ValueType.V_Timestamp;
        } else if (Date.class.equals(clazz)) {
            return ValueType.V_Date;
        } else if (Time.class.equals(clazz)) {
            return ValueType.V_Time;
        } else if (BigDecimal.class.equals(clazz)) {
            return ValueType.V_BigDecimal;
        } else if (BigInteger.class.equals(clazz)) {
            return ValueType.V_BigInteger;
        } else if (LocalDateTime.class.equals(clazz)) {
            return ValueType.V_LocalDateTime;
        } else if (LocalDate.class.equals(clazz)) {
            return ValueType.V_LocalDate;
        } else if (Duration.class.equals(clazz)) {
            return ValueType.V_Duration;
        } else if (LocalTime.class.equals(clazz)) {
            return ValueType.V_LocalTime;
        } else if (Period.class.equals(clazz)) {
            return ValueType.V_Period;
        } else if (OffsetDateTime.class.equals(clazz)) {
            return ValueType.V_OffsetDateTime;
        } else {
            return ValueType.Unsupported;
        }
    }