protected DataType getMapping()

in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog/CrateDBTypeMapper.java [41:53]

• 13 lines of code
• 5 McCabe index (conditional complexity)

    protected DataType getMapping(String pgType, int precision, int scale) {
        switch (pgType) {
            case PG_SERIAL:
            case PG_BIGSERIAL:
                return null;
            case PG_STRING:
                return DataTypes.STRING();
            case PG_STRING_ARRAY:
                return DataTypes.ARRAY(DataTypes.STRING());
            default:
                return super.getMapping(pgType, precision, scale);
        }
    }