Index

B C J P S W
All Classes and Interfaces|All Packages

B

build() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Returns the source based on the properties set so far.

C

changeRecord() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets the return type of the source to ChangeRecord.

com.hazelcast.enterprise.jet.cdc.postgres - package com.hazelcast.enterprise.jet.cdc.postgres

PostgreSQL-specific CDC API.

customMapping(RecordMappingFunction<T_NEW>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets the return type of the source to user defined #T_NEW type.

J

json() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets the return type of the source to Map.Entry with key and value being SourceRecord's key and value, parsed to json string.

P

postgres(String) - Static method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources

Creates a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.

PostgresCdcSources - Class in com.hazelcast.enterprise.jet.cdc.postgres

Contains factory methods for creating change data capture sources based on PostgreSQL databases.

PostgresCdcSources.Builder<T> - Class in com.hazelcast.enterprise.jet.cdc.postgres

Builder for configuring a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.

PostgresSequenceExtractor - Class in com.hazelcast.enterprise.jet.cdc.postgres

PostgresSequenceExtractor() - Constructor for class com.hazelcast.enterprise.jet.cdc.postgres.PostgresSequenceExtractor

S

sequence(Map<String, ?>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresSequenceExtractor

setColumnIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.

setCustomSnapshotter(Class<?>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Custom snapshotter that will be used by the connector.

setDatabaseAddress(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

IP address or hostname of the database server, has to be specified.

setDatabaseAddress(String, int) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

IP address or hostname and the port of the database server, has to be specified.

setDatabaseCredentials(String, String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Database user and password for connecting to the database server.

setDatabaseExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Optional regular expressions that match databases to be excluded from monitoring; any table not included in the exclude list will be monitored.

setDatabaseIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Optional regular expressions that match databases to be monitored; any database not included in the include list will be excluded from monitoring.

setDatabaseName(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

The name of the PostgreSQL database from which to stream the changes.

setDatabasePassword(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Database user password for connecting to the database server.

setDatabasePort(int) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Optional port number of the database server, if unspecified defaults to the database specific default port (5432).

setDatabaseUser(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Database user for connecting to the database server.

setLogicalDecodingPlugIn(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

The name of the @see Postgres logical decoding plug-in installed on the server.

setProperty(String, boolean) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets a source property.

setProperty(String, int) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets a source property.

setProperty(String, long) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets a source property.

setProperty(String, String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets a source property.

setPublicationName(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

The name of the Postgres publication that will be used for CDC purposes.

setReplicationSlotDropOnStop(boolean) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Whether to drop the logical replication slot when the connector disconnects cleanly.

setReplicationSlotName(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

The name of the @see Postgres logical decoding slot (also called "replication slot") created for streaming changes from a plug-in and database instance.

setSchemaExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Optional regular expressions that match schema names to be excluded from monitoring ("schema" is used here to denote logical groups of tables).

setSchemaIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Optional regular expressions that match schema names to be monitored ("schema" is used here to denote logical groups of tables).

setSnapshotMode(DebeziumSnapshotMode) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Snapshot mode that will be used by the connector.

setSslCertificateFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Specifies the (path to the) file containing the SSL Certificate for the database client.

setSslKeyFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Specifies the (path to the) file containing the SSL private key of the database client.

setSslKeyFilePassword(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Specifies the password to be used to access the SSL key file, if specified.

setSslMode(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Specifies whether to use an encrypted connection to the database.

setSslRootCertificateFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Specifies the file containing SSL certificate authority (CA) certificate(s).

setTableExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

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.

setTableIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

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.

source(Map<String, ?>, Map<String, ?>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresSequenceExtractor

W

withAsyncEngine() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Changes the engine used to async embedded engine.

withDefaultEngine() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Changes the engine used to default embedded engine.

withErrorMaxRetries(int) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets the maximum retry count in case of errors.

withSequenceExtractor(Class<? extends SequenceExtractor>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder

Sets the SequenceExtractor class property.

B C J P S W
All Classes and Interfaces|All Packages