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

Class SqlServerSourceConfig

java.lang.Object

org.apache.flink.cdc.connectors.base.config.BaseSourceConfig

org.apache.flink.cdc.connectors.base.config.JdbcSourceConfig

org.apache.flink.cdc.connectors.sqlserver.source.config.SqlServerSourceConfig

All Implemented Interfaces:

Serializable, SourceConfig

public class SqlServerSourceConfig
extends JdbcSourceConfig

Describes the connection information of the SQL Server database and the configuration information for performing snapshotting and streaming reading, such as splitSize.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.cdc.connectors.base.config.SourceConfig

SourceConfig.Factory<C extends SourceConfig>

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.base.config.JdbcSourceConfig

chunkKeyColumn, connectionPoolSize, connectMaxRetries, connectTimeout, databaseList, driverClassName, fetchSize, hostname, password, port, schemaList, serverTimeZone, tableList, username

Fields inherited from class org.apache.flink.cdc.connectors.base.config.BaseSourceConfig

assignUnboundedChunkFirst, closeIdleReaders, dbzConfiguration, dbzProperties, distributionFactorLower, distributionFactorUpper, includeSchemaChanges, isScanNewlyAddedTableEnabled, releaseSnapshotMetadataEnabled, skipSnapshotBackfill, splitMetaGroupSize, splitSize, startupOptions

Constructor Summary

Constructors

Constructor

Description

SqlServerSourceConfig(StartupOptions startupOptions, List<String> databaseList, List<String> tableList, int splitSize, int splitMetaGroupSize, double distributionFactorUpper, double distributionFactorLower, boolean includeSchemaChanges, boolean closeIdleReaders, Properties dbzProperties, io.debezium.config.Configuration dbzConfiguration, String driverClassName, String hostname, int port, String username, String password, int fetchSize, String serverTimeZone, java.time.Duration connectTimeout, int connectMaxRetries, int connectionPoolSize, String chunkKeyColumn, boolean skipSnapshotBackfill, boolean scanNewlyAddedTableEnabled, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)

Method Summary

Modifier and Type	Method	Description
io.debezium.connector.sqlserver.SqlServerConnectorConfig	getDbzConnectorConfig()

Methods inherited from class org.apache.flink.cdc.connectors.base.config.JdbcSourceConfig

getChunkKeyColumn, getConnectionPoolSize, getConnectMaxRetries, getConnectTimeout, getDatabaseList, getDriverClassName, getFetchSize, getHostname, getPassword, getPort, getServerTimeZone, getTableFilters, getTableList, getUsername, isScanNewlyAddedTableEnabled

Methods inherited from class org.apache.flink.cdc.connectors.base.config.BaseSourceConfig

getDbzConfiguration, getDbzProperties, getDistributionFactorLower, getDistributionFactorUpper, getSplitMetaGroupSize, getSplitSize, getStartupOptions, isAssignUnboundedChunkFirst, isCloseIdleReaders, isIncludeSchemaChanges, isReleaseSnapshotMetadataEnabled, isSkipSnapshotBackfill

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlServerSourceConfig

public SqlServerSourceConfig(StartupOptions startupOptions,
                             List<String> databaseList,
                             List<String> tableList,
                             int splitSize,
                             int splitMetaGroupSize,
                             double distributionFactorUpper,
                             double distributionFactorLower,
                             boolean includeSchemaChanges,
                             boolean closeIdleReaders,
                             Properties dbzProperties,
                             io.debezium.config.Configuration dbzConfiguration,
                             String driverClassName,
                             String hostname,
                             int port,
                             String username,
                             String password,
                             int fetchSize,
                             String serverTimeZone,
                             java.time.Duration connectTimeout,
                             int connectMaxRetries,
                             int connectionPoolSize,
                             String chunkKeyColumn,
                             boolean skipSnapshotBackfill,
                             boolean scanNewlyAddedTableEnabled,
                             boolean assignUnboundedChunkFirst,
                             boolean releaseSnapshotMetadataEnabled)

Method Detail

getDbzConnectorConfig

public io.debezium.connector.sqlserver.SqlServerConnectorConfig getDbzConnectorConfig()

Specified by:

getDbzConnectorConfig in class JdbcSourceConfig