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

Class MySqlSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceOptions

public class MySqlSourceOptions
extends Object

Configurations for MySqlSource.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<Double>	CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static org.apache.flink.configuration.ConfigOption<Double>	CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
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<Boolean>	PARSE_ONLINE_SCHEMA_CHANGES
static org.apache.flink.configuration.ConfigOption<String>	PASSWORD
static org.apache.flink.configuration.ConfigOption<Integer>	PORT
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static org.apache.flink.configuration.ConfigOption<String>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN
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_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_NEWLY_ADDED_TABLE_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_READ_CHANGELOG_AS_APPEND_ONLY_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<String>	SCAN_STARTUP_SPECIFIC_OFFSET_GTID_SET
static org.apache.flink.configuration.ConfigOption<Long>	SCAN_STARTUP_SPECIFIC_OFFSET_POS
static org.apache.flink.configuration.ConfigOption<Long>	SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_EVENTS
static org.apache.flink.configuration.ConfigOption<Long>	SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_ROWS
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<String>	TABLE_NAME
static org.apache.flink.configuration.ConfigOption<Boolean>	USE_LEGACY_JSON_FORMAT
static org.apache.flink.configuration.ConfigOption<String>	USERNAME

Constructor Summary

Constructors

Constructor	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<Long> SCAN_STARTUP_SPECIFIC_OFFSET_POS

SCAN_STARTUP_SPECIFIC_OFFSET_GTID_SET

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

SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_EVENTS

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

SCAN_STARTUP_SPECIFIC_OFFSET_SKIP_ROWS

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

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

SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED

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

CHUNK_META_GROUP_SIZE

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

CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND

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

CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Double> CHUNK_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

SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED

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

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

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

SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED

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

SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

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

PARSE_ONLINE_SCHEMA_CHANGES

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

USE_LEGACY_JSON_FORMAT

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

SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST

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

Constructor Detail

MySqlSourceOptions

public MySqlSourceOptions()