Package org.apache.flink.cdc.connectors.mysql

Class MySqlSource.Builder<T>

java.lang.Object

org.apache.flink.cdc.connectors.mysql.MySqlSource.Builder<T>

Enclosing class:

MySqlSource

@Deprecated
public static class MySqlSource.Builder<T>
extends Object

Deprecated.

please use 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.

Builder class of MySqlSource.

Constructor Summary

Constructors

Constructor	Description
Builder()	Deprecated.

Method Summary

Modifier and Type	Method	Description
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(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>	useLegacyJsonFormat(boolean useLegacyJsonFormat)	Deprecated.
MySqlSource.Builder<T>	username(String username)	Deprecated. Name of the MySQL database to use when connecting to the MySQL database server.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Deprecated.

Method Detail

hostname

public MySqlSource.Builder<T> hostname(String hostname)

Deprecated.

port

public MySqlSource.Builder<T> port(int port)

Deprecated.

Integer port number of the MySQL database server.

databaseList

public 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. By default all databases will be monitored.

tableList

public 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. Each identifier is of the form databaseName.tableName. By default the connector will monitor every non-system table in each monitored database.

username

public MySqlSource.Builder<T> username(String username)

Deprecated.

Name of the MySQL database to use when connecting to the MySQL database server.

password

public MySqlSource.Builder<T> password(String password)

Deprecated.

Password to use when connecting to the MySQL database server.

serverTimeZone

public MySqlSource.Builder<T> serverTimeZone(String timeZone)

Deprecated.

The session time zone in database server, e.g. "America/Los_Angeles". It controls how the TIMESTAMP type in MYSQL converted to STRING. See more https://debezium.io/documentation/reference/1.9/connectors/mysql.html#mysql-temporal-types

serverId

public 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. This connector joins the MySQL database cluster as another server (with this unique ID) so it can read the binlog. By default, a random number is generated between 5400 and 6400, though we recommend setting an explicit value.

debeziumProperties

public MySqlSource.Builder<T> debeziumProperties(Properties properties)

Deprecated.

The Debezium MySQL connector properties. For example, "snapshot.mode".

deserializer

public MySqlSource.Builder<T> deserializer(DebeziumDeserializationSchema<T> deserializer)

Deprecated.

The deserializer used to convert from consumed SourceRecord.

startupOptions

public MySqlSource.Builder<T> startupOptions(StartupOptions startupOptions)

Deprecated.

Specifies the startup options.

useLegacyJsonFormat

public MySqlSource.Builder<T> useLegacyJsonFormat(boolean useLegacyJsonFormat)

Deprecated.

build

public DebeziumSourceFunction<T> build()

Deprecated.