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

Class JdbcSourceConfig

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, SourceConfig

Direct Known Subclasses:

Db2SourceConfig, OracleSourceConfig, PostgresSourceConfig, SqlServerSourceConfig

public abstract class JdbcSourceConfig
extends BaseSourceConfig

A Source configuration which is used by IncrementalSource which used JDBC data source.

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

Modifier and Type	Field	Description
protected String	chunkKeyColumn
protected int	connectionPoolSize
protected int	connectMaxRetries
protected java.time.Duration	connectTimeout
protected List<String>	databaseList
protected String	driverClassName
protected int	fetchSize
protected String	hostname
protected String	password
protected int	port
protected List<String>	schemaList
protected String	serverTimeZone
protected List<String>	tableList
protected String	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

JdbcSourceConfig(StartupOptions startupOptions, List<String> databaseList, List<String> schemaList, 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 isScanNewlyAddedTableEnabled, boolean assignUnboundedChunkFirst, boolean releaseSnapshotMetadataEnabled)

Method Summary

Modifier and Type	Method	Description
String	getChunkKeyColumn()
int	getConnectionPoolSize()
int	getConnectMaxRetries()
java.time.Duration	getConnectTimeout()
List<String>	getDatabaseList()
abstract io.debezium.relational.RelationalDatabaseConnectorConfig	getDbzConnectorConfig()
String	getDriverClassName()
int	getFetchSize()
String	getHostname()
String	getPassword()
int	getPort()
String	getServerTimeZone()
RelationalTableFilters	getTableFilters()
List<String>	getTableList()
String	getUsername()
boolean	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

Field Detail

driverClassName

protected final String driverClassName

hostname

protected final String hostname

port

protected final int port

username

protected final String username

password

protected final String password

databaseList

protected final List<String> databaseList

schemaList

protected final List<String> schemaList

tableList

protected final List<String> tableList

fetchSize

protected final int fetchSize

serverTimeZone

protected final String serverTimeZone

connectTimeout

protected final java.time.Duration connectTimeout

connectMaxRetries

protected final int connectMaxRetries

connectionPoolSize

protected final int connectionPoolSize

chunkKeyColumn

protected final String chunkKeyColumn

Constructor Detail

JdbcSourceConfig

public JdbcSourceConfig(StartupOptions startupOptions,
                        List<String> databaseList,
                        List<String> schemaList,
                        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 isScanNewlyAddedTableEnabled,
                        boolean assignUnboundedChunkFirst,
                        boolean releaseSnapshotMetadataEnabled)

Method Detail

getDbzConnectorConfig

public abstract io.debezium.relational.RelationalDatabaseConnectorConfig getDbzConnectorConfig()

getDriverClassName

public String getDriverClassName()

getHostname

public String getHostname()

getPort

public int getPort()

getUsername

public String getUsername()

getPassword

public String getPassword()

getDatabaseList

public List<String> getDatabaseList()

getTableList

public List<String> getTableList()

getFetchSize

public int getFetchSize()

getServerTimeZone

public String getServerTimeZone()

getConnectTimeout

public java.time.Duration getConnectTimeout()

getConnectMaxRetries

public int getConnectMaxRetries()

getConnectionPoolSize

public int getConnectionPoolSize()

getChunkKeyColumn

public String getChunkKeyColumn()

isScanNewlyAddedTableEnabled

public boolean isScanNewlyAddedTableEnabled()

getTableFilters

public RelationalTableFilters getTableFilters()