Uses of Class
com.hazelcast.jet.cdc.postgres.PostgresCdcSources.Builder

Packages that use PostgresCdcSources.Builder

Package	Description
com.hazelcast.jet.cdc.postgres	Contains connectors for change data capture events from PostgreSQL databases.

Uses of PostgresCdcSources.Builder in com.hazelcast.jet.cdc.postgres

Methods in com.hazelcast.jet.cdc.postgres that return PostgresCdcSources.Builder

Modifier and Type	Method and Description
static PostgresCdcSources.Builder	PostgresCdcSources.postgres(String name) Creates a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setColumnBlacklist(String... columnNameRegExps) Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setCommitPeriod(long milliseconds) Specifies how often the connector should confirm processed offsets to the Postgres database's replication slot.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setCustomProperty(String key, String value) Can be used to set any property not explicitly covered by other methods or to override internal properties.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setCustomSnapshotter(Class<?> snapshotterClass) Custom snapshotter that will be used by the connector.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setDatabaseAddress(String address) IP address or hostname of the database server, has to be specified.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setDatabaseName(String dbName) The name of the PostgreSQL database from which to stream the changes.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setDatabasePassword(String password) Database user password for connecting to the database server.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setDatabasePort(int port) Optional port number of the database server, if unspecified defaults to the database specific default port (5432).
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setDatabaseUser(String user) Database user for connecting to the database server.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setLogicalDecodingPlugIn(String pluginName) The name of the @see Postgres logical decoding plug-in installed on the server.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setPublicationName(String publicationName) The name of the Postgres publication that will be used for CDC purposes.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setReconnectBehavior(RetryStrategy retryStrategy) Specifies how the connector should behave when it detects that the backing database has been shut dow.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setReplicationSlotDropOnStop(boolean dropOnStop) Whether or not to drop the logical replication slot when the connector disconnects cleanly.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setReplicationSlotName(String slotName) The name of the @see Postgres logical decoding slot (also called "replication slot") created for streaming changes from a plug-in and database instance.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setSchemaBlacklist(String... schemaNameRegExps) Optional regular expressions that match schema names to be excluded from monitoring ("schema" is used here to denote logical groups of tables).
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setSchemaWhitelist(String... schemaNameRegExps) Optional regular expressions that match schema names to be monitored ("schema" is used here to denote logical groups of tables).
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setShouldStateBeResetOnReconnect(boolean reset) Specifies if the source's state should be kept or discarded during reconnect attempts to the database.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setSnapshotMode(PostgresCdcSources.PostgresSnapshotMode snapshotMode) Snapshot mode that will be used by the connector.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setSslCertificateFile(String file) Specifies the (path to the) file containing the SSL Certificate for the database client.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setSslKeyFile(String file) Specifies the (path to the) file containing the SSL private key of the database client.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setSslKeyFilePassword(String password) Specifies the password to be used to access the SSL key file, if specified.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setSslMode(String mode) Specifies whether to use an encrypted connection to the database.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setSslRootCertificateFile(String file) Specifies the file containing containing SSL certificate authority (CA) certificate(s).
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setTableBlacklist(String... tableNameRegExps) Optional regular expressions that match fully-qualified table identifiers for tables to be excluded from monitoring; any table not included in the blacklist will be monitored.
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setTableWhitelist(String... tableNameRegExps) Optional 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.