public static FieldType mapConnectorFieldType()

in connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/ColumnParser.java [74:104]

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

    public static FieldType mapConnectorFieldType(String dataType) {

        switch (dataType) {
            case "tinyint":
            case "smallint":
            case "mediumint":
            case "int":
                return FieldType.INT32;
//            case "bigint":
//                return FieldType.BIG_INTEGER;
            case "tinytext":
            case "text":
            case "mediumtext":
            case "longtext":
            case "varchar":
            case "char":
                return FieldType.STRING;
            case "date":
            case "datetime":
            case "timestamp":
            case "time":
            case "year":
                return FieldType.DATETIME;
            case "enum":
                return null;
            case "set":
                return null;
            default:
                return FieldType.BYTES;
        }
    }