public static ConfigDef config()

in hologres-connector-kafka/src/main/java/com/alibaba/hologres/kafka/conf/HoloSinkConfig.java [199:560]
324 lines of code
1 McCabe index (conditional complexity)

    public static ConfigDef config() {
        ConfigDef config = new ConfigDef();
        // CONFIG_CONNECTION_GROUP
        config.define(
                JDBC_URL,
                ConfigDef.Type.STRING,
                ConfigDef.NO_DEFAULT_VALUE,
                ConfigDef.Importance.HIGH,
                JDBC_URL_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                JDBC_URL_DISPLAY);

        config.define(
                TABLE,
                ConfigDef.Type.STRING,
                ConfigDef.NO_DEFAULT_VALUE,
                ConfigDef.Importance.HIGH,
                TABLE_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                TABLE_DISPLAY);

        config.define(
                USERNAME,
                ConfigDef.Type.STRING,
                ConfigDef.NO_DEFAULT_VALUE,
                ConfigDef.Importance.HIGH,
                USERNAME_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                USERNAME_DISPLAY);

        config.define(
                PASSWORD,
                ConfigDef.Type.STRING,
                ConfigDef.NO_DEFAULT_VALUE,
                ConfigDef.Importance.HIGH,
                PASSWORD_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                PASSWORD_DISPLAY);

        config.define(
                WRITE_MODE,
                ConfigDef.Type.STRING,
                WRITE_MODE_DEFAULT,
                ConfigDef.Importance.HIGH,
                WRITE_MODE_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                WRITE_MODE_DISPLAY);

        config.define(
                WRITE_BATCH_SIZE,
                ConfigDef.Type.INT,
                WRITE_BATCH_SIZE_DEFAULT,
                ConfigDef.Importance.HIGH,
                WRITE_BATCH_SIZE_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                WRITE_BATCH_SIZE_DISPLAY);

        config.define(
                WRITE_BATCH_BYTE_SIZE,
                ConfigDef.Type.LONG,
                WRITE_BATCH_BYTE_SIZE_DEFAULT,
                ConfigDef.Importance.HIGH,
                WRITE_BATCH_BYTE_SIZE_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                WRITE_BATCH_BYTE_SIZE_DISPLAY);

        config.define(
                WRITE_MAX_INTERVAL_MS,
                ConfigDef.Type.LONG,
                WRITE_MAX_INTERVAL_MS_DEFAULT,
                ConfigDef.Importance.HIGH,
                WRITE_MAX_INTERVAL_MS_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                WRITE_MAX_INTERVAL_MS_DISPLAY);

        config.define(
                WRITE_FAIL_STRATEGY,
                ConfigDef.Type.STRING,
                WRITE_FAIL_STRATEGY_DEFAULT,
                ConfigDef.Importance.HIGH,
                WRITE_FAIL_STRATEGY_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                WRITE_FAIL_STRATEGY_DISPLAY);

        config.define(
                USE_LEGACY_PUT_HANDLER,
                ConfigDef.Type.BOOLEAN,
                USE_LEGACY_PUT_HANDLER_DEFAULT,
                ConfigDef.Importance.HIGH,
                USE_LEGACY_PUT_HANDLER_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                USE_LEGACY_PUT_HANDLER_DISPLAY);

        config.define(
                DYNAMIC_PARTITION,
                ConfigDef.Type.BOOLEAN,
                DYNAMIC_PARTITION_DEFAULT,
                ConfigDef.Importance.HIGH,
                DYNAMIC_PARTITION_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                DYNAMIC_PARTITION_DISPLAY);

        config.define(
                WRITE_THREAD_SIZE,
                ConfigDef.Type.INT,
                WRITE_THREAD_SIZE_DEFAULT,
                ConfigDef.Importance.HIGH,
                WRITE_THREAD_SIZE_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                WRITE_THREAD_SIZE_DISPLAY);

        config.define(
                RETRY_COUNT,
                ConfigDef.Type.INT,
                RETRY_COUNT_DEFAULT,
                ConfigDef.Importance.HIGH,
                RETRY_COUNT_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                RETRY_COUNT_DISPLAY);

        config.define(
                RETRY_SLEEP_INIT_MS,
                ConfigDef.Type.LONG,
                RETRY_SLEEP_INIT_MS_DEFAULT,
                ConfigDef.Importance.HIGH,
                RETRY_SLEEP_INIT_MS_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                RETRY_SLEEP_INIT_MS_DISPLAY);

        config.define(
                RETRY_SLEEP_STEP_MS,
                ConfigDef.Type.LONG,
                RETRY_SLEEP_STEP_MS_DEFAULT,
                ConfigDef.Importance.HIGH,
                RETRY_SLEEP_STEP_MS_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                RETRY_SLEEP_STEP_MS_DISPLAY);

        config.define(
                CONNECTION_MAX_IDLE_MS,
                ConfigDef.Type.LONG,
                CONNECTION_MAX_IDLE_MS_DEFAULT,
                ConfigDef.Importance.HIGH,
                CONNECTION_MAX_IDLE_MS_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                CONNECTION_MAX_IDLE_MS_DISPLAY);

        config.define(
                FIXED_CONNECTION_MODE,
                ConfigDef.Type.BOOLEAN,
                FIXED_CONNECTION_MODE_DEFAULT,
                ConfigDef.Importance.HIGH,
                FIXED_CONNECTION_MODE_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                FIXED_CONNECTION_MODE_DISPLAY);

        config.define(
                COPY_WRITE_MODE,
                ConfigDef.Type.BOOLEAN,
                COPY_WRITE_MODE_DEFAULT,
                ConfigDef.Importance.HIGH,
                COPY_WRITE_MODE_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                COPY_WRITE_MODE_DISPLAY);

        config.define(
                COPY_WRITE_DIRTY_DATA_CHECK,
                ConfigDef.Type.BOOLEAN,
                COPY_WRITE_DIRTY_DATA_CHECK_DEFAULT,
                ConfigDef.Importance.HIGH,
                COPY_WRITE_DIRTY_DATA_CHECK_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                COPY_WRITE_DIRTY_DATA_CHECK_DISPLAY);

        config.define(
                COPY_WRITE_FORMAT,
                ConfigDef.Type.STRING,
                COPY_WRITE_FORMAT_DEFAULT,
                ConfigDef.Importance.HIGH,
                COPY_WRITE_FORMAT_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                COPY_WRITE_FORMAT_DISPLAY);

        config.define(
                COPY_WRITE_DIRECT_CONNECT,
                ConfigDef.Type.BOOLEAN,
                COPY_WRITE_DIRECT_CONNECT_DEFAULT,
                ConfigDef.Importance.HIGH,
                COPY_WRITE_DIRECT_CONNECT_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                COPY_WRITE_DIRECT_CONNECT_DISPLAY);

        // CONFIG_CONVERT_GROUP
        config.define(
                INPUT_FORMAT,
                ConfigDef.Type.STRING,
                INPUT_FORMAT_DEFAULT,
                ConfigDef.Importance.HIGH,
                INPUT_FORMAT_DOC,
                CONFIG_CONVERT_GROUP,
                1,
                ConfigDef.Width.LONG,
                INPUT_FORMAT_DISPLAY);

        // CONFIG_MESSAGE_GROUP
        config.define(
                WHOLE_MESSAGE_INFO,
                ConfigDef.Type.BOOLEAN,
                WHOLE_MESSAGE_INFO_DEFAULT,
                ConfigDef.Importance.HIGH,
                WHOLE_MESSAGE_INFO_DOC,
                CONFIG_MESSAGE_GROUP,
                1,
                ConfigDef.Width.LONG,
                WHOLE_MESSAGE_INFO_DISPLAY);

        config.define(
                MESSAGE_TOPIC,
                ConfigDef.Type.STRING,
                MESSAGE_TOPIC_DEFAULT,
                ConfigDef.Importance.HIGH,
                MESSAGE_TOPIC_DOC,
                CONFIG_MESSAGE_GROUP,
                1,
                ConfigDef.Width.LONG,
                MESSAGE_TOPIC_DISPLAY);

        config.define(
                MESSAGE_PARTITION,
                ConfigDef.Type.STRING,
                MESSAGE_PARTITION_DEFAULT,
                ConfigDef.Importance.HIGH,
                MESSAGE_PARTITION_DOC,
                CONFIG_MESSAGE_GROUP,
                1,
                ConfigDef.Width.LONG,
                MESSAGE_PARTITION_DISPLAY);

        config.define(
                MESSAGE_OFFSET,
                ConfigDef.Type.STRING,
                MESSAGE_OFFSET_DEFAULT,
                ConfigDef.Importance.HIGH,
                MESSAGE_OFFSET_DOC,
                CONFIG_MESSAGE_GROUP,
                1,
                ConfigDef.Width.LONG,
                MESSAGE_OFFSET_DISPLAY);

        config.define(
                MESSAGE_TIMESTAMP,
                ConfigDef.Type.STRING,
                MESSAGE_TIMESTAMP_DEFAULT,
                ConfigDef.Importance.HIGH,
                MESSAGE_TIMESTAMP_DOC,
                CONFIG_MESSAGE_GROUP,
                1,
                ConfigDef.Width.LONG,
                MESSAGE_TIMESTAMP_DISPLAY);

        // CONFIG_INITIAL_GROUP
        config.define(
                INITIAL_TIMESTAMP,
                ConfigDef.Type.LONG,
                INITIAL_TIMESTAMP_DEFAULT,
                ConfigDef.Importance.HIGH,
                INITIAL_TIMESTAMP_DOC,
                INITIAL_GROUP,
                1,
                ConfigDef.Width.LONG,
                INITIAL_TIMESTAMP_DISPLAY);

        // CONFIG_DIRTY_DATA_GROUP
        config.define(
                DIRTY_DATA_STRATEGY,
                ConfigDef.Type.STRING,
                DIRTY_DATA_STRATEGY_DEFAULT,
                ConfigDef.Importance.HIGH,
                DIRTY_DATA_STRATEGY_DOC,
                DIRTY_DATA_GROUP,
                1,
                ConfigDef.Width.LONG,
                DIRTY_DATA_STRATEGY_DISPLAY);

        config.define(
                DIRTY_DATA_TO_SKIP_ONCE,
                ConfigDef.Type.LIST,
                DIRTY_DATA_TO_SKIP_ONCE_DEFAULT,
                ConfigDef.Importance.LOW,
                DIRTY_DATA_TO_SKIP_ONCE_DOC,
                DIRTY_DATA_GROUP,
                1,
                ConfigDef.Width.LONG,
                DIRTY_DATA_TO_SKIP_ONCE_DISPLAY);

        config.define(
                SCHEMA_FORCE_CHECK,
                ConfigDef.Type.BOOLEAN,
                SCHEMA_FORCE_CHECK_DEFAULT,
                ConfigDef.Importance.HIGH,
                SCHEMA_FORCE_CHECK_DOC,
                CONFIG_CONNECTION_GROUP,
                1,
                ConfigDef.Width.LONG,
                SCHEMA_FORCE_CHECK_DISPLAY);

        // CONFIG_METRICS_GROUP
        config.define(
                METRICS_REPORT_INTERVAL,
                ConfigDef.Type.INT,
                METRICS_REPORT_INTERVAL_DEFAULT,
                ConfigDef.Importance.HIGH,
                METRICS_REPORT_INTERVAL_DOC,
                METRICS_GROUP,
                1,
                ConfigDef.Width.LONG,
                METRICS_REPORT_INTERVAL_DISPLAY);

        return config;
    }