Uses of Class
org.apache.flink.cdc.common.configuration.ConfigOption

Packages that use ConfigOption

Package	Description
org.apache.flink.cdc.common.configuration
org.apache.flink.cdc.common.factories
org.apache.flink.cdc.common.pipeline
org.apache.flink.cdc.common.source.discover
org.apache.flink.cdc.connectors.doris.factory
org.apache.flink.cdc.connectors.doris.sink
org.apache.flink.cdc.connectors.elasticsearch.sink
org.apache.flink.cdc.connectors.fluss.factory
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.fluss.source
org.apache.flink.cdc.connectors.fluss.source.discover
org.apache.flink.cdc.connectors.hudi.sink
org.apache.flink.cdc.connectors.iceberg.sink
org.apache.flink.cdc.connectors.kafka.sink
org.apache.flink.cdc.connectors.maxcompute
org.apache.flink.cdc.connectors.mysql.factory
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.oceanbase.factory
org.apache.flink.cdc.connectors.oceanbase.sink
org.apache.flink.cdc.connectors.oracle.factory
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.postgres.factory
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.sqlserver.factory
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.connectors.values.factory
org.apache.flink.cdc.connectors.values.sink
org.apache.flink.cdc.connectors.values.source
org.apache.flink.cdc.models.dummy
org.apache.flink.cdc.models.openai
org.apache.flink.cdc.python
org.apache.flink.cdc.runtime.model

Uses of ConfigOption in org.apache.flink.cdc.common.configuration

Methods in org.apache.flink.cdc.common.configuration that return ConfigOption

Modifier and Type	Method	Description
ConfigOption<T>	ConfigOptions.TypedConfigOptionBuilder.defaultValue(T value)	Creates a ConfigOption with the given default value.
ConfigOption<List<E>>	ConfigOptions.ListConfigOptionBuilder.defaultValues(E... values)	Creates a ConfigOption with the given default value.
ConfigOption<List<E>>	ConfigOptions.ListConfigOptionBuilder.noDefaultValue()	Creates a ConfigOption without a default value.
ConfigOption<T>	ConfigOptions.TypedConfigOptionBuilder.noDefaultValue()	Creates a ConfigOption without a default value.
ConfigOption<T>	ConfigOption.withDeprecatedKeys(String... deprecatedKeys)	Creates a new config option, using this option's key and default value, and adding the given deprecated keys.
ConfigOption<T>	ConfigOption.withDescription(String description)	Creates a new config option, using this option's key and default value, and adding the given description.
ConfigOption<T>	ConfigOption.withDescription(Description description)	Creates a new config option, using this option's key and default value, and adding the given description.
ConfigOption<T>	ConfigOption.withFallbackKeys(String... fallbackKeys)	Creates a new config option, using this option's key and default value, and adding the given fallback keys.

Methods in org.apache.flink.cdc.common.configuration with parameters of type ConfigOption

Modifier and Type	Method	Description
static boolean	ConfigurationUtils.canBePrefixMap(ConfigOption<?> configOption)	Maps can be represented in two ways.
boolean	Configuration.contains(ConfigOption<?> configOption)	Checks whether there is an entry for the given config option.
<T> T	Configuration.get(ConfigOption<T> option)
<T> Optional<T>	Configuration.getOptional(ConfigOption<T> option)
<T> boolean	Configuration.remove(ConfigOption<T> configOption)	Removes given config option from the configuration.
<T> Configuration	Configuration.set(ConfigOption<T> option, T value)

Uses of ConfigOption in org.apache.flink.cdc.common.factories

Methods in org.apache.flink.cdc.common.factories that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	Factory.optionalOptions()	Returns a set of ConfigOption that an implementation of this factory consumes in addition to Factory.requiredOptions().
Set<ConfigOption<?>>	Factory.requiredOptions()	Returns a set of ConfigOption that an implementation of this factory requires in addition to Factory.optionalOptions().

Method parameters in org.apache.flink.cdc.common.factories with type arguments of type ConfigOption

Modifier and Type	Method	Description
static void	FactoryHelper.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions, Set<ConfigOption<?>> optionalOptions, Configuration configuration)	Validates the required options and optional options.

Uses of ConfigOption in org.apache.flink.cdc.common.pipeline

Fields in org.apache.flink.cdc.common.pipeline declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<RuntimeExecutionMode>	PipelineOptions.PIPELINE_EXECUTION_RUNTIME_MODE
static ConfigOption<String>	PipelineOptions.PIPELINE_LOCAL_TIME_ZONE
static ConfigOption<String>	PipelineOptions.PIPELINE_NAME
static ConfigOption<String>	PipelineOptions.PIPELINE_OPERATOR_UID_PREFIX
static ConfigOption<Integer>	PipelineOptions.PIPELINE_PARALLELISM
static ConfigOption<HashFunctionStrategy>	PipelineOptions.PIPELINE_PARTITIONING_STRATEGY
static ConfigOption<RouteMode>	PipelineOptions.PIPELINE_ROUTE_MODE
static ConfigOption<SchemaChangeBehavior>	PipelineOptions.PIPELINE_SCHEMA_CHANGE_BEHAVIOR
static ConfigOption<java.time.Duration>	PipelineOptions.PIPELINE_SCHEMA_OPERATOR_RPC_TIMEOUT
static ConfigOption<String>	PipelineOptions.PIPELINE_SCHEMA_OPERATOR_UID	Deprecated.
static ConfigOption<Integer>	PipelineOptions.PIPELINE_TRANSFORM_ASYNC_EXECUTION_CAPACITY
static ConfigOption<Boolean>	PipelineOptions.PIPELINE_TRANSFORM_ASYNC_EXECUTION_ENABLED
static ConfigOption<java.time.Duration>	PipelineOptions.PIPELINE_TRANSFORM_ASYNC_EXECUTION_TIMEOUT
static ConfigOption<Integer>	PipelineOptions.PIPELINE_TRANSFORM_ASYNC_EXECUTION_WORKER_THREADS
static ConfigOption<DecimalPrecisionMode>	PipelineOptions.PIPELINE_TRANSFORM_DECIMAL_PRECISION_MODE

Uses of ConfigOption in org.apache.flink.cdc.common.source.discover

Fields in org.apache.flink.cdc.common.source.discover declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	JdbcTableDiscoverer.COLUMN_NAME
static ConfigOption<String>	JdbcTableDiscoverer.JDBC_URL
static ConfigOption<String>	JdbcTableDiscoverer.PASSWORD
static ConfigOption<String>	JdbcTableDiscoverer.SUBSCRIBE_ID
static ConfigOption<String>	JdbcTableDiscoverer.SUBSCRIBE_ID_COLUMN
static ConfigOption<String>	JdbcTableDiscoverer.SUBSCRIBE_QUERY
static ConfigOption<String>	JdbcTableDiscoverer.TABLE_NAME
static ConfigOption<String>	JdbcTableDiscoverer.USERNAME

Uses of ConfigOption in org.apache.flink.cdc.connectors.doris.factory

Methods in org.apache.flink.cdc.connectors.doris.factory that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	DorisDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	DorisDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.doris.sink

Fields in org.apache.flink.cdc.connectors.doris.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<Boolean>	DorisDataSinkOptions.AUTO_REDIRECT
static ConfigOption<String>	DorisDataSinkOptions.BENODES
static ConfigOption<String>	DorisDataSinkOptions.CHARSET_ENCODING
static ConfigOption<String>	DorisDataSinkOptions.FENODES
static ConfigOption<String>	DorisDataSinkOptions.JDBC_URL
static ConfigOption<String>	DorisDataSinkOptions.PASSWORD
static ConfigOption<Integer>	DorisDataSinkOptions.SINK_BUFFER_COUNT
static ConfigOption<java.time.Duration>	DorisDataSinkOptions.SINK_BUFFER_FLUSH_INTERVAL
static ConfigOption<Integer>	DorisDataSinkOptions.SINK_BUFFER_FLUSH_MAX_BYTES
static ConfigOption<Integer>	DorisDataSinkOptions.SINK_BUFFER_FLUSH_MAX_ROWS
static ConfigOption<Integer>	DorisDataSinkOptions.SINK_BUFFER_SIZE
static ConfigOption<Integer>	DorisDataSinkOptions.SINK_CHECK_INTERVAL
static ConfigOption<Boolean>	DorisDataSinkOptions.SINK_ENABLE_2PC
static ConfigOption<Boolean>	DorisDataSinkOptions.SINK_ENABLE_BATCH_MODE
static ConfigOption<Boolean>	DorisDataSinkOptions.SINK_ENABLE_DELETE
static ConfigOption<Integer>	DorisDataSinkOptions.SINK_FLUSH_QUEUE_SIZE
static ConfigOption<Boolean>	DorisDataSinkOptions.SINK_IGNORE_UPDATE_BEFORE
static ConfigOption<String>	DorisDataSinkOptions.SINK_LABEL_PREFIX
static ConfigOption<Integer>	DorisDataSinkOptions.SINK_MAX_RETRIES
static ConfigOption<Boolean>	DorisDataSinkOptions.SINK_USE_CACHE
static ConfigOption<String>	DorisDataSinkOptions.USERNAME

Uses of ConfigOption in org.apache.flink.cdc.connectors.elasticsearch.sink

Fields in org.apache.flink.cdc.connectors.elasticsearch.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	ElasticsearchDataSinkOptions.HOSTS	The comma-separated list of Elasticsearch hosts to connect to.
static ConfigOption<Integer>	ElasticsearchDataSinkOptions.MAX_BATCH_SIZE	The maximum number of actions to buffer for each bulk request.
static ConfigOption<Long>	ElasticsearchDataSinkOptions.MAX_BATCH_SIZE_IN_BYTES	The maximum size of batch requests in bytes.
static ConfigOption<Integer>	ElasticsearchDataSinkOptions.MAX_BUFFERED_REQUESTS	The maximum number of requests to keep in the in-memory buffer.
static ConfigOption<Integer>	ElasticsearchDataSinkOptions.MAX_IN_FLIGHT_REQUESTS	The maximum number of concurrent requests that the sink will try to execute.
static ConfigOption<Long>	ElasticsearchDataSinkOptions.MAX_RECORD_SIZE_IN_BYTES	The maximum size of a single record in bytes.
static ConfigOption<Long>	ElasticsearchDataSinkOptions.MAX_TIME_IN_BUFFER_MS	The maximum time to wait for incomplete batches before flushing.
static ConfigOption<String>	ElasticsearchDataSinkOptions.PASSWORD	The password for Elasticsearch authentication.
static ConfigOption<String>	ElasticsearchDataSinkOptions.SHARDING_SUFFIX_KEY	The sharding for Elasticsearch index, default sink table name is test_table_${suffix}.
static ConfigOption<String>	ElasticsearchDataSinkOptions.SHARDING_SUFFIX_SEPARATOR	The sharding for Elasticsearch index, default sink table name is test_table_${suffix}.
static ConfigOption<String>	ElasticsearchDataSinkOptions.USERNAME	The username for Elasticsearch authentication.
static ConfigOption<Integer>	ElasticsearchDataSinkOptions.VERSION	The version of Elasticsearch to connect to.

Methods in org.apache.flink.cdc.connectors.elasticsearch.sink that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	ElasticsearchDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	ElasticsearchDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.fluss.factory

Methods in org.apache.flink.cdc.connectors.fluss.factory that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	FlussDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	FlussDataSourceFactory.optionalOptions()
Set<ConfigOption<?>>	FlussDataSinkFactory.requiredOptions()
Set<ConfigOption<?>>	FlussDataSourceFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.fluss.sink

Fields in org.apache.flink.cdc.connectors.fluss.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	FlussDataSinkOptions.BOOTSTRAP_SERVERS
static ConfigOption<String>	FlussDataSinkOptions.BUCKET_KEY
static ConfigOption<String>	FlussDataSinkOptions.BUCKET_NUMBER
static ConfigOption<FlussDataSinkOptions.SinkPartitioningStrategy>	FlussDataSinkOptions.SINK_PARTITIONING_STRATEGY

Uses of ConfigOption in org.apache.flink.cdc.connectors.fluss.source

Fields in org.apache.flink.cdc.connectors.fluss.source declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	FlussDataSourceOptions.BOOTSTRAP_SERVERS
static ConfigOption<java.time.Duration>	FlussDataSourceOptions.SCAN_DISCOVERY_INTERVAL
static ConfigOption<java.time.Duration>	FlussDataSourceOptions.SCAN_KV_SNAPSHOT_LEASE_DURATION
static ConfigOption<String>	FlussDataSourceOptions.SCAN_KV_SNAPSHOT_LEASE_ID
static ConfigOption<String>	FlussDataSourceOptions.SCAN_STARTUP_MODE
static ConfigOption<String>	FlussDataSourceOptions.SCAN_STARTUP_TIMESTAMP
static ConfigOption<String>	FlussDataSourceOptions.TABLE_DISCOVERER_TYPE

Uses of ConfigOption in org.apache.flink.cdc.connectors.fluss.source.discover

Fields in org.apache.flink.cdc.connectors.fluss.source.discover declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	FlussDefaultDiscoverer.PATTERN

Uses of ConfigOption in org.apache.flink.cdc.connectors.hudi.sink

Fields in org.apache.flink.cdc.connectors.hudi.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	HudiConfig.INDEX_TYPE
static ConfigOption<String>	HudiConfig.ORDERING_FIELDS
static ConfigOption<String>	HudiConfig.PATH
static ConfigOption<String>	HudiConfig.TABLE_TYPE
static ConfigOption<Integer>	HudiConfig.WRITE_TASKS

Methods in org.apache.flink.cdc.connectors.hudi.sink that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	HudiDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	HudiDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.iceberg.sink

Fields in org.apache.flink.cdc.connectors.iceberg.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	IcebergDataSinkOptions.CATALOG_IMPL
static ConfigOption<String>	IcebergDataSinkOptions.CLIENT_REGION
static ConfigOption<String>	IcebergDataSinkOptions.GLUE_ID
static ConfigOption<Boolean>	IcebergDataSinkOptions.GLUE_SKIP_ARCHIVE
static ConfigOption<Boolean>	IcebergDataSinkOptions.GLUE_SKIP_NAME_VALIDATION
static ConfigOption<String>	IcebergDataSinkOptions.IO_IMPL
static ConfigOption<String>	IcebergDataSinkOptions.JOB_ID_PREFIX
static ConfigOption<String>	IcebergDataSinkOptions.PARTITION_KEY
static ConfigOption<Integer>	IcebergDataSinkOptions.SINK_COMPACTION_COMMIT_INTERVAL
static ConfigOption<Boolean>	IcebergDataSinkOptions.SINK_COMPACTION_ENABLED
static ConfigOption<Integer>	IcebergDataSinkOptions.SINK_COMPACTION_PARALLELISM
static ConfigOption<String>	IcebergDataSinkOptions.TYPE
static ConfigOption<String>	IcebergDataSinkOptions.WAREHOUSE

Methods in org.apache.flink.cdc.connectors.iceberg.sink that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	IcebergDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	IcebergDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.kafka.sink

Fields in org.apache.flink.cdc.connectors.kafka.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<Boolean>	KafkaDataSinkOptions.DEBEZIUM_JSON_INCLUDE_SCHEMA_ENABLED
static ConfigOption<org.apache.flink.connector.base.DeliveryGuarantee>	KafkaDataSinkOptions.DELIVERY_GUARANTEE
static ConfigOption<KeyFormat>	KafkaDataSinkOptions.KEY_FORMAT
static ConfigOption<PartitionStrategy>	KafkaDataSinkOptions.PARTITION_STRATEGY
static ConfigOption<Boolean>	KafkaDataSinkOptions.SINK_ADD_TABLEID_TO_HEADER_ENABLED
static ConfigOption<String>	KafkaDataSinkOptions.SINK_CUSTOM_HEADER
static ConfigOption<String>	KafkaDataSinkOptions.SINK_TABLE_ID_TO_TOPIC_MAPPING
static ConfigOption<String>	KafkaDataSinkOptions.TOPIC
static ConfigOption<JsonSerializationType>	KafkaDataSinkOptions.VALUE_FORMAT

Methods in org.apache.flink.cdc.connectors.kafka.sink that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	KafkaDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	KafkaDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.maxcompute

Fields in org.apache.flink.cdc.connectors.maxcompute declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	MaxComputeDataSinkOptions.ACCESS_ID
static ConfigOption<String>	MaxComputeDataSinkOptions.ACCESS_KEY
static ConfigOption<String>	MaxComputeDataSinkOptions.BUCKET_BUFFER_SIZE
static ConfigOption<Integer>	MaxComputeDataSinkOptions.BUCKETS_NUM
static ConfigOption<Integer>	MaxComputeDataSinkOptions.COMMIT_THREAD_NUM
static ConfigOption<CompressAlgorithm>	MaxComputeDataSinkOptions.COMPRESS_ALGORITHM
static ConfigOption<String>	MaxComputeDataSinkOptions.ENDPOINT
static ConfigOption<Integer>	MaxComputeDataSinkOptions.FLUSH_CONCURRENT_NUM
static ConfigOption<String>	MaxComputeDataSinkOptions.PROJECT
static ConfigOption<String>	MaxComputeDataSinkOptions.QUOTA_NAME
static ConfigOption<String>	MaxComputeDataSinkOptions.STS_TOKEN
static ConfigOption<String>	MaxComputeDataSinkOptions.TOTAL_BUFFER_SIZE
static ConfigOption<String>	MaxComputeDataSinkOptions.TUNNEL_ENDPOINT

Methods in org.apache.flink.cdc.connectors.maxcompute that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	MaxComputeDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	MaxComputeDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.mysql.factory

Methods in org.apache.flink.cdc.connectors.mysql.factory that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	MySqlDataSourceFactory.optionalOptions()
Set<ConfigOption<?>>	MySqlDataSourceFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.mysql.source

Fields in org.apache.flink.cdc.connectors.mysql.source declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<Double>	MySqlDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	MySqlDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	MySqlDataSourceOptions.CHUNK_META_GROUP_SIZE
static ConfigOption<Integer>	MySqlDataSourceOptions.CONNECT_MAX_RETRIES
static ConfigOption<java.time.Duration>	MySqlDataSourceOptions.CONNECT_TIMEOUT
static ConfigOption<Integer>	MySqlDataSourceOptions.CONNECTION_POOL_SIZE
static ConfigOption<java.time.Duration>	MySqlDataSourceOptions.HEARTBEAT_INTERVAL
static ConfigOption<String>	MySqlDataSourceOptions.HOSTNAME
static ConfigOption<Boolean>	MySqlDataSourceOptions.INCLUDE_COMMENTS_ENABLED
static ConfigOption<String>	MySqlDataSourceOptions.METADATA_LIST
static ConfigOption<Boolean>	MySqlDataSourceOptions.PARSE_ONLINE_SCHEMA_CHANGES
static ConfigOption<String>	MySqlDataSourceOptions.PASSWORD
static ConfigOption<Integer>	MySqlDataSourceOptions.PORT
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static ConfigOption<String>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN
static ConfigOption<Integer>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED
static ConfigOption<Integer>	MySqlDataSourceOptions.SCAN_SNAPSHOT_FETCH_SIZE
static ConfigOption<String>	MySqlDataSourceOptions.SCAN_STARTUP_MODE
static ConfigOption<String>	MySqlDataSourceOptions.SCAN_STARTUP_SPECIFIC_OFFSET_FILE
static ConfigOption<String>	MySqlDataSourceOptions.SCAN_STARTUP_SPECIFIC_OFFSET_GTID_SET
static ConfigOption<Long>	MySqlDataSourceOptions.SCAN_STARTUP_SPECIFIC_OFFSET_POS
static ConfigOption<Long>	MySqlDataSourceOptions.SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_EVENTS
static ConfigOption<Long>	MySqlDataSourceOptions.SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_ROWS
static ConfigOption<Long>	MySqlDataSourceOptions.SCAN_STARTUP_TIMESTAMP_MILLIS
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCHEMA_CHANGE_ENABLED
static ConfigOption<String>	MySqlDataSourceOptions.SERVER_ID
static ConfigOption<String>	MySqlDataSourceOptions.SERVER_TIME_ZONE
static ConfigOption<String>	MySqlDataSourceOptions.TABLES
static ConfigOption<String>	MySqlDataSourceOptions.TABLES_EXCLUDE
static ConfigOption<Boolean>	MySqlDataSourceOptions.TREAT_TINYINT1_AS_BOOLEAN_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.USE_LEGACY_JSON_FORMAT
static ConfigOption<String>	MySqlDataSourceOptions.USERNAME

Uses of ConfigOption in org.apache.flink.cdc.connectors.oceanbase.factory

Methods in org.apache.flink.cdc.connectors.oceanbase.factory that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	OceanBaseDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	OceanBaseDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.oceanbase.sink

Fields in org.apache.flink.cdc.connectors.oceanbase.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<java.time.Duration>	OceanBaseDataSinkOptions.BUFFER_FLUSH_INTERVAL
static ConfigOption<Integer>	OceanBaseDataSinkOptions.BUFFER_SIZE
static ConfigOption<String>	OceanBaseDataSinkOptions.DRIVER_CLASS_NAME
static ConfigOption<String>	OceanBaseDataSinkOptions.DRUID_PROPERTIES
static ConfigOption<Integer>	OceanBaseDataSinkOptions.MAX_RETRIES
static ConfigOption<Boolean>	OceanBaseDataSinkOptions.MEMSTORE_CHECK_ENABLED
static ConfigOption<java.time.Duration>	OceanBaseDataSinkOptions.MEMSTORE_CHECK_INTERVAL
static ConfigOption<Double>	OceanBaseDataSinkOptions.MEMSTORE_THRESHOLD
static ConfigOption<Boolean>	OceanBaseDataSinkOptions.PARTITION_ENABLED
static ConfigOption<String>	OceanBaseDataSinkOptions.PASSWORD
static ConfigOption<Boolean>	OceanBaseDataSinkOptions.SYNC_WRITE
static ConfigOption<String>	OceanBaseDataSinkOptions.URL
static ConfigOption<String>	OceanBaseDataSinkOptions.USERNAME

Uses of ConfigOption in org.apache.flink.cdc.connectors.oracle.factory

Methods in org.apache.flink.cdc.connectors.oracle.factory that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	OracleDataSourceFactory.optionalOptions()
Set<ConfigOption<?>>	OracleDataSourceFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.oracle.source

Fields in org.apache.flink.cdc.connectors.oracle.source declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<Double>	OracleDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	OracleDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	OracleDataSourceOptions.CHUNK_META_GROUP_SIZE
static ConfigOption<Integer>	OracleDataSourceOptions.CONNECT_MAX_RETRIES
static ConfigOption<java.time.Duration>	OracleDataSourceOptions.CONNECT_TIMEOUT
static ConfigOption<Integer>	OracleDataSourceOptions.CONNECTION_POOL_SIZE
static ConfigOption<String>	OracleDataSourceOptions.DATABASE
static ConfigOption<String>	OracleDataSourceOptions.DATABASE_CONNECTION_ADAPTER
static ConfigOption<String>	OracleDataSourceOptions.HOSTNAME
static ConfigOption<String>	OracleDataSourceOptions.JDBC_URL
static ConfigOption<String>	OracleDataSourceOptions.LOG_MINING_STRATEGY
static ConfigOption<String>	OracleDataSourceOptions.METADATA_LIST
static ConfigOption<String>	OracleDataSourceOptions.PASSWORD
static ConfigOption<Integer>	OracleDataSourceOptions.PORT
static ConfigOption<Boolean>	OracleDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	OracleDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static ConfigOption<Integer>	OracleDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE
static ConfigOption<Integer>	OracleDataSourceOptions.SCAN_SNAPSHOT_FETCH_SIZE
static ConfigOption<String>	OracleDataSourceOptions.SCAN_STARTUP_MODE
static ConfigOption<String>	OracleDataSourceOptions.SERVER_TIME_ZONE
static ConfigOption<String>	OracleDataSourceOptions.TABLES
static ConfigOption<String>	OracleDataSourceOptions.USERNAME

Uses of ConfigOption in org.apache.flink.cdc.connectors.paimon.sink

Fields in org.apache.flink.cdc.connectors.paimon.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	PaimonDataSinkOptions.COMMIT_USER
static ConfigOption<String>	PaimonDataSinkOptions.METASTORE
static ConfigOption<String>	PaimonDataSinkOptions.PARTITION_KEY
static ConfigOption<String>	PaimonDataSinkOptions.URI
static ConfigOption<String>	PaimonDataSinkOptions.WAREHOUSE

Methods in org.apache.flink.cdc.connectors.paimon.sink that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	PaimonDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	PaimonDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.postgres.factory

Methods in org.apache.flink.cdc.connectors.postgres.factory that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	PostgresDataSourceFactory.optionalOptions()
Set<ConfigOption<?>>	PostgresDataSourceFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.postgres.source

Fields in org.apache.flink.cdc.connectors.postgres.source declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<Double>	PostgresDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	PostgresDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	PostgresDataSourceOptions.CHUNK_META_GROUP_SIZE
static ConfigOption<Integer>	PostgresDataSourceOptions.CONNECT_MAX_RETRIES
static ConfigOption<java.time.Duration>	PostgresDataSourceOptions.CONNECT_TIMEOUT
static ConfigOption<Integer>	PostgresDataSourceOptions.CONNECTION_POOL_SIZE
static ConfigOption<String>	PostgresDataSourceOptions.DECODING_PLUGIN_NAME
static ConfigOption<java.time.Duration>	PostgresDataSourceOptions.HEARTBEAT_INTERVAL
static ConfigOption<String>	PostgresDataSourceOptions.HOSTNAME
static ConfigOption<String>	PostgresDataSourceOptions.METADATA_LIST
static ConfigOption<String>	PostgresDataSourceOptions.PASSWORD
static ConfigOption<Integer>	PostgresDataSourceOptions.PG_PORT
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static ConfigOption<String>	PostgresDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN
static ConfigOption<Integer>	PostgresDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED
static ConfigOption<Integer>	PostgresDataSourceOptions.SCAN_LSN_COMMIT_CHECKPOINTS_DELAY
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCAN_PRE_EPOCH_TIMESTAMP_WALL_CLOCK_CONVERSION_ENABLED
static ConfigOption<Integer>	PostgresDataSourceOptions.SCAN_SNAPSHOT_FETCH_SIZE
static ConfigOption<String>	PostgresDataSourceOptions.SCAN_STARTUP_MODE
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCHEMA_CHANGE_ENABLED
static ConfigOption<String>	PostgresDataSourceOptions.SERVER_TIME_ZONE
static ConfigOption<String>	PostgresDataSourceOptions.SLOT_NAME
static ConfigOption<Double>	PostgresDataSourceOptions.SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	PostgresDataSourceOptions.SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Boolean>	PostgresDataSourceOptions.TABLE_ID_INCLUDE_DATABASE
static ConfigOption<String>	PostgresDataSourceOptions.TABLES
static ConfigOption<String>	PostgresDataSourceOptions.TABLES_EXCLUDE
static ConfigOption<String>	PostgresDataSourceOptions.USERNAME

Uses of ConfigOption in org.apache.flink.cdc.connectors.sqlserver.factory

Methods in org.apache.flink.cdc.connectors.sqlserver.factory that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	SqlServerDataSourceFactory.optionalOptions()
Set<ConfigOption<?>>	SqlServerDataSourceFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.sqlserver.source

Fields in org.apache.flink.cdc.connectors.sqlserver.source declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<Double>	SqlServerDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	SqlServerDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	SqlServerDataSourceOptions.CHUNK_META_GROUP_SIZE
static ConfigOption<Integer>	SqlServerDataSourceOptions.CONNECT_MAX_RETRIES
static ConfigOption<java.time.Duration>	SqlServerDataSourceOptions.CONNECT_TIMEOUT
static ConfigOption<Integer>	SqlServerDataSourceOptions.CONNECTION_POOL_SIZE
static ConfigOption<String>	SqlServerDataSourceOptions.HOSTNAME
static ConfigOption<String>	SqlServerDataSourceOptions.METADATA_LIST
static ConfigOption<String>	SqlServerDataSourceOptions.PASSWORD
static ConfigOption<Integer>	SqlServerDataSourceOptions.PORT
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static ConfigOption<String>	SqlServerDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN
static ConfigOption<Integer>	SqlServerDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED
static ConfigOption<Integer>	SqlServerDataSourceOptions.SCAN_SNAPSHOT_FETCH_SIZE
static ConfigOption<String>	SqlServerDataSourceOptions.SCAN_STARTUP_MODE
static ConfigOption<Long>	SqlServerDataSourceOptions.SCAN_STARTUP_TIMESTAMP_MILLIS
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCHEMA_CHANGE_ENABLED
static ConfigOption<String>	SqlServerDataSourceOptions.SERVER_TIME_ZONE
static ConfigOption<String>	SqlServerDataSourceOptions.TABLES
static ConfigOption<String>	SqlServerDataSourceOptions.TABLES_EXCLUDE
static ConfigOption<String>	SqlServerDataSourceOptions.USERNAME

Uses of ConfigOption in org.apache.flink.cdc.connectors.starrocks.sink

Fields in org.apache.flink.cdc.connectors.starrocks.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	StarRocksDataSinkOptions.JDBC_URL
static ConfigOption<List<String>>	StarRocksDataSinkOptions.LOAD_URL
static ConfigOption<String>	StarRocksDataSinkOptions.PASSWORD
static ConfigOption<Boolean>	StarRocksDataSinkOptions.SINK_AT_LEAST_ONCE_USE_TRANSACTION_LOAD
static ConfigOption<Long>	StarRocksDataSinkOptions.SINK_BATCH_FLUSH_INTERVAL
static ConfigOption<Long>	StarRocksDataSinkOptions.SINK_BATCH_MAX_SIZE
static ConfigOption<Integer>	StarRocksDataSinkOptions.SINK_CONNECT_TIMEOUT
static ConfigOption<Integer>	StarRocksDataSinkOptions.SINK_IO_THREAD_COUNT
static ConfigOption<String>	StarRocksDataSinkOptions.SINK_LABEL_PREFIX
static ConfigOption<Integer>	StarRocksDataSinkOptions.SINK_METRIC_HISTOGRAM_WINDOW_SIZE
static ConfigOption<Long>	StarRocksDataSinkOptions.SINK_SCAN_FREQUENCY
static ConfigOption<Integer>	StarRocksDataSinkOptions.SINK_SOCKET_TIMEOUT
static ConfigOption<Integer>	StarRocksDataSinkOptions.SINK_WAIT_FOR_CONTINUE_TIMEOUT
static ConfigOption<Integer>	StarRocksDataSinkOptions.TABLE_CREATE_NUM_BUCKETS
static ConfigOption<java.time.Duration>	StarRocksDataSinkOptions.TABLE_SCHEMA_CHANGE_TIMEOUT
static ConfigOption<Integer>	StarRocksDataSinkOptions.UNICODE_CHAR_MAX_BYTES
static ConfigOption<String>	StarRocksDataSinkOptions.USERNAME

Methods in org.apache.flink.cdc.connectors.starrocks.sink that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	StarRocksDataSinkFactory.optionalOptions()
Set<ConfigOption<?>>	StarRocksDataSinkFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.values.factory

Methods in org.apache.flink.cdc.connectors.values.factory that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	ValuesDataFactory.optionalOptions()
Set<ConfigOption<?>>	ValuesDataFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.connectors.values.sink

Fields in org.apache.flink.cdc.connectors.values.sink declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<Boolean>	ValuesDataSinkOptions.ERROR_ON_SCHEMA_CHANGE
static ConfigOption<Boolean>	ValuesDataSinkOptions.MATERIALIZED_IN_MEMORY
static ConfigOption<Boolean>	ValuesDataSinkOptions.PRINT_ENABLED
static ConfigOption<ValuesDataSink.SinkApi>	ValuesDataSinkOptions.SINK_API

Uses of ConfigOption in org.apache.flink.cdc.connectors.values.source

Fields in org.apache.flink.cdc.connectors.values.source declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<Boolean>	ValuesDataSourceOptions.BATCH_MODE_ENABLED
static ConfigOption<ValuesDataSourceHelper.EventSetId>	ValuesDataSourceOptions.EVENT_SET_ID
static ConfigOption<Integer>	ValuesDataSourceOptions.FAILURE_INJECTION_INDEX

Uses of ConfigOption in org.apache.flink.cdc.models.dummy

Methods in org.apache.flink.cdc.models.dummy that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	DummyModelClientFactory.optionalOptions()
Set<ConfigOption<?>>	DummyModelClientFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.models.openai

Fields in org.apache.flink.cdc.models.openai declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	OpenAiCompatibleModelOptions.API_KEY
static ConfigOption<OpenAiCompatibleModelOptions.ContentType>	OpenAiCompatibleModelOptions.CONTENT_TYPE
static ConfigOption<Integer>	OpenAiCompatibleModelOptions.DIMENSION
static ConfigOption<String>	OpenAiCompatibleModelOptions.ENDPOINT
static ConfigOption<ErrorHandlingStrategy>	OpenAiCompatibleModelOptions.ERROR_HANDLING_STRATEGY
static ConfigOption<String>	OpenAiCompatibleModelOptions.EXTRA_BODY
static ConfigOption<String>	OpenAiCompatibleModelOptions.EXTRA_HEADER
static ConfigOption<Double>	OpenAiCompatibleModelOptions.FREQUENCY_PENALTY
static ConfigOption<Integer>	OpenAiCompatibleModelOptions.MAX_TOKENS
static ConfigOption<String>	OpenAiCompatibleModelOptions.MODEL
static ConfigOption<Long>	OpenAiCompatibleModelOptions.N
static ConfigOption<Double>	OpenAiCompatibleModelOptions.PRESENCE_PENALTY
static ConfigOption<OpenAiCompatibleModelOptions.ResponseFormat>	OpenAiCompatibleModelOptions.RESPONSE_FORMAT
static ConfigOption<java.time.Duration>	OpenAiCompatibleModelOptions.RETRY_BACKOFF_BASE_INTERVAL
static ConfigOption<RetryBackoffStrategy>	OpenAiCompatibleModelOptions.RETRY_BACKOFF_STRATEGY
static ConfigOption<ErrorHandlingStrategy>	OpenAiCompatibleModelOptions.RETRY_FALLBACK_STRATEGY
static ConfigOption<Integer>	OpenAiCompatibleModelOptions.RETRY_NUM
static ConfigOption<Long>	OpenAiCompatibleModelOptions.SEED
static ConfigOption<String>	OpenAiCompatibleModelOptions.STOP
static ConfigOption<String>	OpenAiCompatibleModelOptions.SYSTEM_PROMPT
static ConfigOption<Double>	OpenAiCompatibleModelOptions.TEMPERATURE
static ConfigOption<Double>	OpenAiCompatibleModelOptions.TOP_P
static ConfigOption<String>	OpenAiCompatibleModelOptions.USER_PROMPT

Fields in org.apache.flink.cdc.models.openai with type parameters of type ConfigOption

Modifier and Type	Field	Description
static Set<ConfigOption<?>>	OpenAiCompatibleModelOptions.ALL_OPTIONS

Methods in org.apache.flink.cdc.models.openai that return types with arguments of type ConfigOption

Modifier and Type	Method	Description
Set<ConfigOption<?>>	OpenAiCompatibleModelClientFactory.optionalOptions()
Set<ConfigOption<?>>	OpenAiCompatibleModelClientFactory.requiredOptions()

Uses of ConfigOption in org.apache.flink.cdc.python

Fields in org.apache.flink.cdc.python declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	PythonUdf.OPTION_PYTHON_EXECUTABLE
static ConfigOption<String>	PythonUdf.OPTION_PYTHON_FILES
static ConfigOption<String>	PythonUdf.OPTION_SOURCE

Uses of ConfigOption in org.apache.flink.cdc.runtime.model

Fields in org.apache.flink.cdc.runtime.model declared as ConfigOption

Modifier and Type	Field	Description
static ConfigOption<String>	ModelOptions.OPENAI_API_KEY
static ConfigOption<String>	ModelOptions.OPENAI_CHAT_PROMPT
static ConfigOption<String>	ModelOptions.OPENAI_HOST
static ConfigOption<String>	ModelOptions.OPENAI_MODEL_NAME