Package org.apache.flink.cdc.connectors.base.options

Class JdbcSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.base.options.SourceOptions

org.apache.flink.cdc.connectors.base.options.JdbcSourceOptions

Direct Known Subclasses:

OracleSourceOptions, PostgresSourceOptions

public class JdbcSourceOptions
extends SourceOptions

Configurations for IncrementalSource of JDBC data source.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<Integer>	CONNECT_MAX_RETRIES
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	CONNECT_TIMEOUT
static org.apache.flink.configuration.ConfigOption<Integer>	CONNECTION_POOL_SIZE
static org.apache.flink.configuration.ConfigOption<String>	DATABASE_NAME
static org.apache.flink.configuration.ConfigOption<String>	HOSTNAME
static org.apache.flink.configuration.ConfigOption<String>	PASSWORD
static org.apache.flink.configuration.ConfigOption<String>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN
static org.apache.flink.configuration.ConfigOption<String>	SCHEMA_NAME
static org.apache.flink.configuration.ConfigOption<String>	SERVER_ID
static org.apache.flink.configuration.ConfigOption<String>	SERVER_TIME_ZONE
static org.apache.flink.configuration.ConfigOption<String>	TABLE_NAME
static org.apache.flink.configuration.ConfigOption<String>	USERNAME

Fields inherited from class org.apache.flink.cdc.connectors.base.options.SourceOptions

CHUNK_META_GROUP_SIZE, SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED, SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP, SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE, SCAN_INCREMENTAL_SNAPSHOT_ENABLED, SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED, SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED, SCAN_NEWLY_ADDED_TABLE_ENABLED, SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED, SCAN_SNAPSHOT_FETCH_SIZE, SCAN_STARTUP_MODE, SCAN_STARTUP_SPECIFIC_OFFSET_FILE, SCAN_STARTUP_SPECIFIC_OFFSET_POS, SCAN_STARTUP_TIMESTAMP_MILLIS, SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND, SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

Constructor Summary

Constructors

Constructor	Description
JdbcSourceOptions()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

HOSTNAME

public static final org.apache.flink.configuration.ConfigOption<String> HOSTNAME

USERNAME

public static final org.apache.flink.configuration.ConfigOption<String> USERNAME

PASSWORD

public static final org.apache.flink.configuration.ConfigOption<String> PASSWORD

DATABASE_NAME

public static final org.apache.flink.configuration.ConfigOption<String> DATABASE_NAME

SCHEMA_NAME

public static final org.apache.flink.configuration.ConfigOption<String> SCHEMA_NAME

TABLE_NAME

public static final org.apache.flink.configuration.ConfigOption<String> TABLE_NAME

SERVER_TIME_ZONE

public static final org.apache.flink.configuration.ConfigOption<String> SERVER_TIME_ZONE

SERVER_ID

public static final org.apache.flink.configuration.ConfigOption<String> SERVER_ID

CONNECT_TIMEOUT

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> CONNECT_TIMEOUT

CONNECTION_POOL_SIZE

public static final org.apache.flink.configuration.ConfigOption<Integer> CONNECTION_POOL_SIZE

CONNECT_MAX_RETRIES

public static final org.apache.flink.configuration.ConfigOption<Integer> CONNECT_MAX_RETRIES

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

public static final org.apache.flink.configuration.ConfigOption<String> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

Constructor Detail

JdbcSourceOptions

public JdbcSourceOptions()