java.lang.Object
- org.apache.flink.cdc.connectors.postgres.PostgreSQLSource.Builder<T>

Enclosing class:: PostgreSQLSource

public static class PostgreSQLSource.Builder<T>
extends Object

Builder class of PostgreSQLSource.

Constructor Summary

Constructors
Constructor Description

Builder()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`DebeziumSourceFunction<T>`	`build()`
`PostgreSQLSource.Builder<T>`	`database(String database)`	The name of the PostgreSQL database from which to stream the changes.
`PostgreSQLSource.Builder<T>`	`debeziumProperties(Properties properties)`	The Debezium Postgres connector properties.
`PostgreSQLSource.Builder<T>`	`decodingPluginName(String name)`	The name of the Postgres logical decoding plug-in installed on the server.
`PostgreSQLSource.Builder<T>`	`deserializer(DebeziumDeserializationSchema<T> deserializer)`	The deserializer used to convert from consumed `SourceRecord`.
`PostgreSQLSource.Builder<T>`	`hostname(String hostname)`
`PostgreSQLSource.Builder<T>`	`password(String password)`	Password to use when connecting to the PostgreSQL database server.
`PostgreSQLSource.Builder<T>`	`port(int port)`	Integer port number of the PostgreSQL database server.
`PostgreSQLSource.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.
`PostgreSQLSource.Builder<T>`	`slotName(String slotName)`	The name of the PostgreSQL logical decoding slot that was created for streaming changes from a particular plug-in for a particular database/schema.
`PostgreSQLSource.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 whitelist will be excluded from monitoring.
`PostgreSQLSource.Builder<T>`	`username(String username)`	Name of the PostgreSQL database to use when connecting to the PostgreSQL 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
  - decodingPluginName
```
public PostgreSQLSource.Builder<T> decodingPluginName(String name)
```
    The name of the Postgres logical decoding plug-in installed on the server. Supported values are decoderbufs, wal2json, wal2json_rds, wal2json_streaming, wal2json_rds_streaming and pgoutput.
  - hostname
```
public PostgreSQLSource.Builder<T> hostname(String hostname)
```
  - port
```
public PostgreSQLSource.Builder<T> port(int port)
```
    Integer port number of the PostgreSQL database server.
  - database
```
public PostgreSQLSource.Builder<T> database(String database)
```
    The name of the PostgreSQL database from which to stream the changes.
  - schemaList
```
public PostgreSQLSource.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.
  - tableList
```
public PostgreSQLSource.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 whitelist 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 schema.
  - username
```
public PostgreSQLSource.Builder<T> username(String username)
```
    Name of the PostgreSQL database to use when connecting to the PostgreSQL database server.
  - password
```
public PostgreSQLSource.Builder<T> password(String password)
```
    Password to use when connecting to the PostgreSQL database server.
  - slotName
```
public PostgreSQLSource.Builder<T> slotName(String slotName)
```
    The name of the PostgreSQL logical decoding slot that was created for streaming changes from a particular plug-in for a particular database/schema. The server uses this slot to stream events to the connector that you are configuring.
    Slot names must conform to PostgreSQL replication slot naming rules, which state: "Each replication slot has a name, which can contain lower-case letters, numbers, and the underscore character."
  - debeziumProperties
```
public PostgreSQLSource.Builder<T> debeziumProperties(Properties properties)
```
    The Debezium Postgres connector properties.
  - deserializer
```
public PostgreSQLSource.Builder<T> deserializer(DebeziumDeserializationSchema<T> deserializer)
```
    The deserializer used to convert from consumed SourceRecord.
  - build
```
public DebeziumSourceFunction<T> build()
```

Class PostgreSQLSource.Builder<T>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Builder

Method Detail

decodingPluginName

hostname

port

database

schemaList

tableList

username

password

slotName

debeziumProperties

deserializer

build