MySqlSource.builder() instead which supports
more rich features, e.g. parallel reading from historical data. The MySqlSource.Builder will be dropped in the future version.@Deprecated public static class MySqlSource.Builder<T> extends Object
MySqlSource.| Constructor and Description |
|---|
Builder()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
com.ververica.cdc.debezium.DebeziumSourceFunction<T> |
build()
Deprecated.
|
MySqlSource.Builder<T> |
databaseList(String... databaseList)
Deprecated.
An optional list of regular expressions that match database names to be monitored; any
database name not included in the whitelist will be excluded from monitoring.
|
MySqlSource.Builder<T> |
debeziumProperties(Properties properties)
Deprecated.
The Debezium MySQL connector properties.
|
MySqlSource.Builder<T> |
deserializer(com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> deserializer)
Deprecated.
The deserializer used to convert from consumed
SourceRecord. |
MySqlSource.Builder<T> |
hostname(String hostname)
Deprecated.
|
MySqlSource.Builder<T> |
password(String password)
Deprecated.
Password to use when connecting to the MySQL database server.
|
MySqlSource.Builder<T> |
port(int port)
Deprecated.
Integer port number of the MySQL database server.
|
MySqlSource.Builder<T> |
serverId(int serverId)
Deprecated.
A numeric ID of this database client, which must be unique across all currently-running
database processes in the MySQL cluster.
|
MySqlSource.Builder<T> |
serverTimeZone(String timeZone)
Deprecated.
The session time zone in database server, e.g.
|
MySqlSource.Builder<T> |
startupOptions(StartupOptions startupOptions)
Deprecated.
Specifies the startup options.
|
MySqlSource.Builder<T> |
tableList(String... tableList)
Deprecated.
An optional 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.
|
MySqlSource.Builder<T> |
username(String username)
Deprecated.
Name of the MySQL database to use when connecting to the MySQL database server.
|
public MySqlSource.Builder<T> hostname(String hostname)
public MySqlSource.Builder<T> port(int port)
public MySqlSource.Builder<T> databaseList(String... databaseList)
public MySqlSource.Builder<T> tableList(String... tableList)
public MySqlSource.Builder<T> username(String username)
public MySqlSource.Builder<T> password(String password)
public MySqlSource.Builder<T> serverTimeZone(String timeZone)
public MySqlSource.Builder<T> serverId(int serverId)
public MySqlSource.Builder<T> debeziumProperties(Properties properties)
public MySqlSource.Builder<T> deserializer(com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> deserializer)
SourceRecord.public MySqlSource.Builder<T> startupOptions(StartupOptions startupOptions)
public com.ververica.cdc.debezium.DebeziumSourceFunction<T> build()
Copyright © 2022 The Apache Software Foundation. All rights reserved.