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

Class SqlServerSource.Builder<T>

java.lang.Object

org.apache.flink.cdc.connectors.sqlserver.SqlServerSource.Builder<T>

Enclosing class:

SqlServerSource

public static class SqlServerSource.Builder<T>
extends Object

Builder class of SqlServerSource.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
DebeziumSourceFunction<T>	build()
SqlServerSource.Builder<T>	database(String database)	The name of the SQL Server database from which to stream the changes.
SqlServerSource.Builder<T>	debeziumProperties(Properties properties)	The Debezium SqlServer connector properties.
SqlServerSource.Builder<T>	deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.
SqlServerSource.Builder<T>	hostname(String hostname)
SqlServerSource.Builder<T>	password(String password)	Password to use when connecting to the SQL Server database server.
SqlServerSource.Builder<T>	port(int port)	Integer port number of the SQL Server database server.
SqlServerSource.Builder<T>	startupOptions(StartupOptions startupOptions)	Specifies the startup options.
SqlServerSource.Builder<T>	tableList(String... tableList)	An optional comma-separated list of regular expressions that match fully-qualified table identifiers for tables that you want Debezium to capture; any table that is not included in table.include.list is excluded from capture.
SqlServerSource.Builder<T>	username(String username)	Username to use when connecting to the SQL Server 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()

Method Detail

hostname

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

port

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

Integer port number of the SQL Server database server.

database

public SqlServerSource.Builder<T> database(String database)

The name of the SQL Server database from which to stream the changes.

tableList

public SqlServerSource.Builder<T> tableList(String... tableList)

An optional comma-separated list of regular expressions that match fully-qualified table identifiers for tables that you want Debezium to capture; any table that is not included in table.include.list is excluded from capture. Each identifier is of the form schemaName.tableName. By default, the connector captures all non-system tables for the designated schemas. Must not be used with table.exclude.list.

username

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

Username to use when connecting to the SQL Server database server.

password

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

Password to use when connecting to the SQL Server database server.

debeziumProperties

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

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

deserializer

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

The deserializer used to convert from consumed SourceRecord.

startupOptions

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

Specifies the startup options.

build

public DebeziumSourceFunction<T> build()