public static void validateSink()

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


    public static void validateSink(ReadableConfig config, TableSchema tableSchema) {
        int fieldNum = tableSchema.getFieldCount();
        if (fieldNum <= 0) {
            throw new RuntimeException("invalid fieldNum, get " + fieldNum);
        }
        validateRequiredConfigOptions(config);
        validateStringConfigOption(config, ADBSSHOST);
        validateIntegerConfigOption(config, ADBSSPORT);
        validateIntegerConfigOption(config, RETRY_WAIT_TIME);
        validateIntegerConfigOption(config, BATCH_SIZE);
        validateIntegerConfigOption(config, BATCH_WRITE_TIMEOUT_MS);
        validateIntegerConfigOption(config, MAX_RETRY_TIMES);
        validateIntegerConfigOption(config, CONNECTION_MAX_ACTIVE);
        validateStringEnumConfigOption(config, CONFLICT_MODE, ConflictMode.stringList());
        validateIntegerEnumConfigOption(config, USE_COPY, ZeroOrOneEnum.integerList());
        validateStringConfigOption(config, TARGET_SCHEMA);
        validateStringEnumConfigOption(config, EXCEPTION_MODE, ExceptionMode.stringList());
        validateIntegerEnumConfigOption(config, RESERVEMS, ZeroOrOneEnum.integerList());
        validateIntegerEnumConfigOption(config, CASE_SENSITIVE, ZeroOrOneEnum.integerList());
        validateIntegerEnumConfigOption(config, WRITE_MODE, WriteMode.integerList());
        validateStringConfigOption(config, DELIMITER);
        validateIntegerEnumConfigOption(config, VERBOSE, ZeroOrOneEnum.integerList());
    }