Uses of Class
com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder

Packages that use MySqlSourceBuilder

Package	Description
com.ververica.cdc.connectors.mysql.source

Uses of MySqlSourceBuilder in com.ververica.cdc.connectors.mysql.source

Methods in com.ververica.cdc.connectors.mysql.source that return MySqlSourceBuilder

Modifier and Type	Method and Description
static <T> MySqlSourceBuilder<T>	MySqlSource.builder() Get a MySqlParallelSourceBuilder to build a MySqlSource.
MySqlSourceBuilder<T>	MySqlSourceBuilder.connectionPoolSize(int connectionPoolSize) The connection pool size.
MySqlSourceBuilder<T>	MySqlSourceBuilder.connectMaxRetries(int connectMaxRetries) The max retry times to get connection.
MySqlSourceBuilder<T>	MySqlSourceBuilder.connectTimeout(java.time.Duration connectTimeout) The maximum time that the connector should wait after trying to connect to the MySQL database server before timing out.
MySqlSourceBuilder<T>	MySqlSourceBuilder.databaseList(String... databaseList) An required list of regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded from monitoring.
MySqlSourceBuilder<T>	MySqlSourceBuilder.debeziumProperties(Properties properties) The Debezium MySQL connector properties.
MySqlSourceBuilder<T>	MySqlSourceBuilder.deserializer(com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> deserializer) The deserializer used to convert from consumed SourceRecord.
MySqlSourceBuilder<T>	MySqlSourceBuilder.distributionFactorLower(double distributionFactorLower) The lower bound of split key evenly distribution factor, the factor is used to determine whether the table is evenly distribution or not.
MySqlSourceBuilder<T>	MySqlSourceBuilder.distributionFactorUpper(double distributionFactorUpper) The upper bound of split key evenly distribution factor, the factor is used to determine whether the table is evenly distribution or not.
MySqlSourceBuilder<T>	MySqlSourceBuilder.fetchSize(int fetchSize) The maximum fetch size for per poll when read table snapshot.
MySqlSourceBuilder<T>	MySqlSourceBuilder.heartbeatInterval(java.time.Duration heartbeatInterval) The interval of heartbeat event.
MySqlSourceBuilder<T>	MySqlSourceBuilder.hostname(String hostname)
MySqlSourceBuilder<T>	MySqlSourceBuilder.includeSchemaChanges(boolean includeSchemaChanges) Whether the MySqlSource should output the schema changes or not.
MySqlSourceBuilder<T>	MySqlSourceBuilder.jdbcProperties(Properties jdbcProperties) Custom properties that will overwrite the default JDBC connection URL.
MySqlSourceBuilder<T>	MySqlSourceBuilder.password(String password) Password to use when connecting to the MySQL database server.
MySqlSourceBuilder<T>	MySqlSourceBuilder.port(int port) Integer port number of the MySQL database server.
MySqlSourceBuilder<T>	MySqlSourceBuilder.scanNewlyAddedTableEnabled(boolean scanNewlyAddedTableEnabled) Whether the MySqlSource should scan the newly added tables or not.
MySqlSourceBuilder<T>	MySqlSourceBuilder.serverId(String serverId) A numeric ID or a numeric ID range of this database client, The numeric ID syntax is like '5400', the numeric ID range syntax is like '5400-5408', The numeric ID range syntax is required when 'scan.incremental.snapshot.enabled' enabled.
MySqlSourceBuilder<T>	MySqlSourceBuilder.serverTimeZone(String timeZone) The session time zone in database server, e.g.
MySqlSourceBuilder<T>	MySqlSourceBuilder.splitMetaGroupSize(int splitMetaGroupSize) The group size of split meta, if the meta size exceeds the group size, the meta will be will be divided into multiple groups.
MySqlSourceBuilder<T>	MySqlSourceBuilder.splitSize(int splitSize) The split size (number of rows) of table snapshot, captured tables are split into multiple splits when read the snapshot of table.
MySqlSourceBuilder<T>	MySqlSourceBuilder.startupOptions(StartupOptions startupOptions) Specifies the startup options.
MySqlSourceBuilder<T>	MySqlSourceBuilder.tableList(String... tableList) An required list of regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the list will be excluded from monitoring.
MySqlSourceBuilder<T>	MySqlSourceBuilder.username(String username) Name of the MySQL database to use when connecting to the MySQL database server.