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

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

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

Modifier and Type	Method	Description
PostgresCdcSources.Builder<com.hazelcast.enterprise.jet.cdc.ChangeRecord>	PostgresCdcSources.Builder.changeRecord()	Sets the return type of the source to ChangeRecord.
<T_NEW> PostgresCdcSources.Builder<T_NEW>	PostgresCdcSources.Builder.customMapping(com.hazelcast.enterprise.jet.cdc.RecordMappingFunction<T_NEW> recordMappingFunction)	Sets the return type of the source to user defined #T_NEW type.
PostgresCdcSources.Builder<Map.Entry<String,String>>	PostgresCdcSources.Builder.json()	Sets the return type of the source to Map.Entry with key and value being SourceRecord's key and value, parsed to json string.
static PostgresCdcSources.Builder<com.hazelcast.enterprise.jet.cdc.ChangeRecord>	PostgresCdcSources.postgres(String name)	Creates a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setColumnIncludeList(String... columnNameRegExps)	Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setCustomSnapshotter(Class<?> snapshotterClass)	Custom snapshotter that will be used by the connector.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabaseAddress(String address)	IP address or hostname of the database server, has to be specified.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabaseAddress(String address, int port)	IP address or hostname and the port of the database server, has to be specified.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabaseCredentials(String user, String password)	Database user and password for connecting to the database server.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabaseExcludeList(String... databaseNameRegExps)	Optional regular expressions that match databases to be excluded from monitoring; any table not included in the exclude list will be monitored.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabaseIncludeList(String... databaseNameRegExps)	Optional regular expressions that match databases to be monitored; any database not included in the include list will be excluded from monitoring.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabaseName(String dbName)	The name of the PostgreSQL database from which to stream the changes.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabasePassword(String password)	Database user password for connecting to the database server.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabasePort(int port)	Optional port number of the database server, if unspecified defaults to the database specific default port (5432).
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setDatabaseUser(String user)	Database user for connecting to the database server.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setLogicalDecodingPlugIn(String pluginName)	The name of the @see Postgres logical decoding plug-in installed on the server.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setProperty(String key, boolean value)	Sets a source property.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setProperty(String key, int value)	Sets a source property.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setProperty(String key, long value)	Sets a source property.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setProperty(String key, String value)	Sets a source property.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setPublicationName(String publicationName)	The name of the Postgres publication that will be used for CDC purposes.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setReplicationSlotDropOnStop(boolean dropOnStop)	Whether to drop the logical replication slot when the connector disconnects cleanly.
PostgresCdcSources.Builder<T>	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<T>	PostgresCdcSources.Builder.setSchemaExcludeList(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<T>	PostgresCdcSources.Builder.setSchemaIncludeList(String... schemaNameRegExps)	Optional regular expressions that match schema names to be monitored ("schema" is used here to denote logical groups of tables).
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setSnapshotMode(com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode snapshotMode)	Snapshot mode that will be used by the connector.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setSslCertificateFile(String file)	Specifies the (path to the) file containing the SSL Certificate for the database client.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setSslKeyFile(String file)	Specifies the (path to the) file containing the SSL private key of the database client.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setSslKeyFilePassword(String password)	Specifies the password to be used to access the SSL key file, if specified.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setSslMode(String mode)	Specifies whether to use an encrypted connection to the database.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setSslRootCertificateFile(String file)	Specifies the file containing SSL certificate authority (CA) certificate(s).
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.setTableExcludeList(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<T>	PostgresCdcSources.Builder.setTableIncludeList(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.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.withAsyncEngine()	Changes the engine used to async embedded engine.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.withDefaultEngine()	Changes the engine used to default embedded engine.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.withErrorMaxRetries(int errorRetryCount)	Sets the maximum retry count in case of errors.
PostgresCdcSources.Builder<T>	PostgresCdcSources.Builder.withSequenceExtractor(Class<? extends com.hazelcast.enterprise.jet.cdc.SequenceExtractor> sequenceExtractorClass)	Sets the SequenceExtractor class property.