in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgOptions.java [280:301]
public static WriteMode getWriteMode(ReadableConfig readableConfig) {
switch (readableConfig.get(WRITE_MODE).toString().toLowerCase()) {
case "insert":
case "0":
return WriteMode.insert;
case "copy":
case "1":
return WriteMode.copy;
case "upsert":
case "2":
return WriteMode.upsert;
case "merge":
case "3":
return WriteMode.merge;
default:
throw new IllegalArgumentException(
String.format(
"Invalid value for config %s : %s",
WRITE_MODE.key(),
readableConfig.get(WRITE_MODE)));
}
}