public static ConflictMode getConflictMode()

in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgOptions.java [261:278]

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

    public static ConflictMode getConflictMode(ReadableConfig readableConfig) {
        switch (readableConfig.get(CONFLICT_MODE).toLowerCase()) {
            case "ignore":
                return ConflictMode.ignore;
            case "strict":
                return ConflictMode.strict;
            case "update":
                return ConflictMode.update;
            case "upsert":
                return ConflictMode.upsert;
            default:
                throw new IllegalArgumentException(
                        String.format(
                                "Invalid value for config %s : %s",
                                CONFLICT_MODE.key(),
                                readableConfig.get(CONFLICT_MODE)));
        }
    }