Package org.apache.flink.cdc.connectors.mysql.source

Class MySqlDataSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.MySqlDataSourceOptions

@PublicEvolving
public class MySqlDataSourceOptions
extends Object

Configurations for MySqlDataSource.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
MySqlDataSourceOptions()

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 ConfigOption<String> HOSTNAME

PORT

public static final ConfigOption<Integer> PORT

USERNAME

public static final ConfigOption<String> USERNAME

PASSWORD

public static final ConfigOption<String> PASSWORD

TABLES

public static final ConfigOption<String> TABLES

SERVER_TIME_ZONE

public static final ConfigOption<String> SERVER_TIME_ZONE

SERVER_ID

public static final ConfigOption<String> SERVER_ID

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE

public static final ConfigOption<Integer> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE

SCAN_SNAPSHOT_FETCH_SIZE

public static final ConfigOption<Integer> SCAN_SNAPSHOT_FETCH_SIZE

CONNECT_TIMEOUT

public static final ConfigOption<java.time.Duration> CONNECT_TIMEOUT

CONNECTION_POOL_SIZE

public static final ConfigOption<Integer> CONNECTION_POOL_SIZE

CONNECT_MAX_RETRIES

public static final ConfigOption<Integer> CONNECT_MAX_RETRIES

SCAN_STARTUP_MODE

public static final ConfigOption<String> SCAN_STARTUP_MODE

SCAN_STARTUP_SPECIFIC_OFFSET_FILE

public static final ConfigOption<String> SCAN_STARTUP_SPECIFIC_OFFSET_FILE

SCAN_STARTUP_SPECIFIC_OFFSET_POS

public static final ConfigOption<Long> SCAN_STARTUP_SPECIFIC_OFFSET_POS

SCAN_STARTUP_SPECIFIC_OFFSET_GTID_SET

public static final ConfigOption<String> SCAN_STARTUP_SPECIFIC_OFFSET_GTID_SET

SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_EVENTS

public static final ConfigOption<Long> SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_EVENTS

SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_ROWS

public static final ConfigOption<Long> SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_ROWS

SCAN_STARTUP_TIMESTAMP_MILLIS

public static final ConfigOption<Long> SCAN_STARTUP_TIMESTAMP_MILLIS

HEARTBEAT_INTERVAL

public static final ConfigOption<java.time.Duration> HEARTBEAT_INTERVAL

CHUNK_META_GROUP_SIZE

@Experimental
public static final ConfigOption<Integer> CHUNK_META_GROUP_SIZE

CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

@Experimental
public static final ConfigOption<Double> CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

@Experimental
public static final ConfigOption<Double> CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

@Experimental
public static final ConfigOption<String> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED

SCAN_NEWLY_ADDED_TABLE_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_NEWLY_ADDED_TABLE_ENABLED

SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED

SCHEMA_CHANGE_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCHEMA_CHANGE_ENABLED

TABLES_EXCLUDE

@Experimental
public static final ConfigOption<String> TABLES_EXCLUDE

SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED

METADATA_LIST

@Experimental
public static final ConfigOption<String> METADATA_LIST

PARSE_ONLINE_SCHEMA_CHANGES

@Experimental
public static final ConfigOption<Boolean> PARSE_ONLINE_SCHEMA_CHANGES

INCLUDE_COMMENTS_ENABLED

@Experimental
public static final ConfigOption<Boolean> INCLUDE_COMMENTS_ENABLED

TREAT_TINYINT1_AS_BOOLEAN_ENABLED

@Experimental
public static final ConfigOption<Boolean> TREAT_TINYINT1_AS_BOOLEAN_ENABLED

USE_LEGACY_JSON_FORMAT

@Experimental
public static final ConfigOption<Boolean> USE_LEGACY_JSON_FORMAT

SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED

SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

Constructor Detail

MySqlDataSourceOptions

public MySqlDataSourceOptions()