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

Class SqlServerDataSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.sqlserver.source.SqlServerDataSourceOptions

@PublicEvolving
public class SqlServerDataSourceOptions
extends Object

Configurations for SqlServerDataSource.

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<String>	HOSTNAME
static ConfigOption<String>	METADATA_LIST
static ConfigOption<String>	PASSWORD
static ConfigOption<Integer>	PORT
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_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<Long>	SCAN_STARTUP_TIMESTAMP_MILLIS
static ConfigOption<Boolean>	SCHEMA_CHANGE_ENABLED
static ConfigOption<String>	SERVER_TIME_ZONE
static ConfigOption<String>	TABLES
static ConfigOption<String>	TABLES_EXCLUDE
static ConfigOption<String>	USERNAME

Constructor Summary

Constructors

Constructor	Description
SqlServerDataSourceOptions()

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

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

public static final ConfigOption<String> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN

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_TIMESTAMP_MILLIS

public static final ConfigOption<Long> SCAN_STARTUP_TIMESTAMP_MILLIS

SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

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_CLOSE_IDLE_READER_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED

SCHEMA_CHANGE_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCHEMA_CHANGE_ENABLED

TABLES_EXCLUDE

@Experimental
public static final ConfigOption<String> TABLES_EXCLUDE

METADATA_LIST

@Experimental
public static final ConfigOption<String> METADATA_LIST

SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED

SCAN_NEWLY_ADDED_TABLE_ENABLED

@Experimental
public static final ConfigOption<Boolean> SCAN_NEWLY_ADDED_TABLE_ENABLED

Constructor Detail

SqlServerDataSourceOptions

public SqlServerDataSourceOptions()