com.ververica.cdc.connectors.mysql.source.config

Class MySqlSourceOptions

java.lang.Object

com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions

public class MySqlSourceOptions
extends Object

Configurations for MySqlSource.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.flink.configuration.ConfigOption<Integer>	CHUNK_META_GROUP_SIZE
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<java.time.Duration>	HEARTBEAT_INTERVAL
static org.apache.flink.configuration.ConfigOption<String>	HOSTNAME
static org.apache.flink.configuration.ConfigOption<String>	PASSWORD
static org.apache.flink.configuration.ConfigOption<Integer>	PORT
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_NEWLY_ADDED_TABLE_ENABLED
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_SNAPSHOT_FETCH_SIZE
static org.apache.flink.configuration.ConfigOption<String>	SCAN_STARTUP_MODE
static org.apache.flink.configuration.ConfigOption<String>	SCAN_STARTUP_SPECIFIC_OFFSET_FILE
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_STARTUP_SPECIFIC_OFFSET_POS
static org.apache.flink.configuration.ConfigOption<Long>	SCAN_STARTUP_TIMESTAMP_MILLIS
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<Double>	SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static org.apache.flink.configuration.ConfigOption<Double>	SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static org.apache.flink.configuration.ConfigOption<String>	TABLE_NAME
static org.apache.flink.configuration.ConfigOption<String>	USERNAME

Constructor Summary

Constructors

Constructor and Description
MySqlSourceOptions()

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

PORT

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

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

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

SCAN_INCREMENTAL_SNAPSHOT_ENABLED

public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ENABLED

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE

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

SCAN_SNAPSHOT_FETCH_SIZE

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

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_STARTUP_MODE

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

SCAN_STARTUP_SPECIFIC_OFFSET_FILE

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

SCAN_STARTUP_SPECIFIC_OFFSET_POS

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

SCAN_STARTUP_TIMESTAMP_MILLIS

public static final org.apache.flink.configuration.ConfigOption<Long> SCAN_STARTUP_TIMESTAMP_MILLIS

HEARTBEAT_INTERVAL

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

CHUNK_META_GROUP_SIZE

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Integer> CHUNK_META_GROUP_SIZE

SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Double> SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Double> SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

SCAN_NEWLY_ADDED_TABLE_ENABLED

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_NEWLY_ADDED_TABLE_ENABLED

Constructor Detail

MySqlSourceOptions

public MySqlSourceOptions()