public static DataType toFlinkType()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/utils/KuduTypeUtils.java [47:75]

• 28 lines of code
• 12 McCabe index (conditional complexity)

    public static DataType toFlinkType(Type type, ColumnTypeAttributes typeAttributes) {
        switch (type) {
            case STRING:
                return DataTypes.STRING();
            case FLOAT:
                return DataTypes.FLOAT();
            case INT8:
                return DataTypes.TINYINT();
            case INT16:
                return DataTypes.SMALLINT();
            case INT32:
                return DataTypes.INT();
            case INT64:
                return DataTypes.BIGINT();
            case DOUBLE:
                return DataTypes.DOUBLE();
            case DECIMAL:
                return DataTypes.DECIMAL(typeAttributes.getPrecision(), typeAttributes.getScale());
            case BOOL:
                return DataTypes.BOOLEAN();
            case BINARY:
                return DataTypes.BYTES();
            case UNIXTIME_MICROS:
                return new AtomicDataType(new TimestampType(3), Timestamp.class);

            default:
                throw new IllegalArgumentException("Illegal var type: " + type);
        }
    }