Package org.apache.flink.cdc.connectors.oracle

Class OracleSource.Builder<T>

java.lang.Object

org.apache.flink.cdc.connectors.oracle.OracleSource.Builder<T>

Enclosing class:

OracleSource

public static class OracleSource.Builder<T>
extends Object

Builder class of OracleSource.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
DebeziumSourceFunction<T>	build()
OracleSource.Builder<T>	database(String database)	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.
OracleSource.Builder<T>	debeziumProperties(Properties properties)	The Debezium Oracle connector properties.
OracleSource.Builder<T>	deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.
OracleSource.Builder<T>	hostname(String hostname)
OracleSource.Builder<T>	password(String password)	Password to use when connecting to the Oracle database server.
OracleSource.Builder<T>	port(Integer port)	Integer port number of the Oracle database server.
OracleSource.Builder<T>	schemaList(String... schemaList)	An optional list of regular expressions that match schema names to be monitored; any schema name not included in the whitelist will be excluded from monitoring.
OracleSource.Builder<T>	startupOptions(StartupOptions startupOptions)	Specifies the startup options.
OracleSource.Builder<T>	tableList(String... tableList)	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.
OracleSource.Builder<T>	url(String url)	Url to use when connecting to the Oracle database server.
OracleSource.Builder<T>	username(String username)	Name of the Oracle database to use when connecting to the Oracle 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 OracleSource.Builder<T> hostname(@Nullable
                                        String hostname)

port

public OracleSource.Builder<T> port(@Nullable
                                    Integer port)

Integer port number of the Oracle database server.

url

public OracleSource.Builder<T> url(@Nullable
                                   String url)

Url to use when connecting to the Oracle database server.

database

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

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 OracleSource.Builder<T> tableList(String... tableList)

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 schemaName.tableName. By default the connector will monitor every non-system table in each monitored database.

schemaList

public OracleSource.Builder<T> schemaList(String... schemaList)

An optional list of regular expressions that match schema names to be monitored; any schema name not included in the whitelist will be excluded from monitoring. By default all non-system schemas will be monitored.

username

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

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

password

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

Password to use when connecting to the Oracle database server.

debeziumProperties

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

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

deserializer

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

The deserializer used to convert from consumed SourceRecord.

startupOptions

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

Specifies the startup options.

build

public DebeziumSourceFunction<T> build()