Index

A B C I N P S V
All Classes and Interfaces|All Packages

A

ALWAYS - Enum constant in enum class com.hazelcast.jet.cdc.postgres.PostgresCdcSources.PostgresSnapshotMode

Always perform a snapshot when starting.

B

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

Returns the source based on the properties set so far.

C

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

Contains connectors for change data capture events from PostgreSQL databases.

I

INITIAL - Enum constant in enum class com.hazelcast.jet.cdc.postgres.PostgresCdcSources.PostgresSnapshotMode

Perform a snapshot only upon initial startup of a connector.

INITIAL_ONLY - Enum constant in enum class com.hazelcast.jet.cdc.postgres.PostgresCdcSources.PostgresSnapshotMode

Perform a snapshot and then stop before attempting to receive any logical changes.

N

NEVER - Enum constant in enum class com.hazelcast.jet.cdc.postgres.PostgresCdcSources.PostgresSnapshotMode

Never perform a snapshot and only receive logical changes.

P

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

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

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

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

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

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

PostgresCdcSources.PostgresSnapshotMode - Enum Class in com.hazelcast.jet.cdc.postgres

Possible postgres snapshot modes, that does not require additional mandatory parameters to be set.

S

setColumnBlacklist(String...) - Method in class com.hazelcast.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.

setCommitPeriod(long) - Method in class com.hazelcast.jet.cdc.postgres.PostgresCdcSources.Builder

Specifies how often the connector should confirm processed offsets to the Postgres database's replication slot.

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

Can be used to set any property not explicitly covered by other methods or to override internal properties.

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

Custom snapshotter that will be used by the connector.

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

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

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

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

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

Database user password for connecting to the database server.

setDatabasePort(int) - Method in class com.hazelcast.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.jet.cdc.postgres.PostgresCdcSources.Builder

Database user for connecting to the database server.

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

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

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

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

setReconnectBehavior(RetryStrategy) - Method in class com.hazelcast.jet.cdc.postgres.PostgresCdcSources.Builder

Specifies how the connector should behave when it detects that the backing database has been shut dow.

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

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

setReplicationSlotName(String) - Method in class com.hazelcast.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.

setSchemaBlacklist(String...) - Method in class com.hazelcast.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).

setSchemaWhitelist(String...) - Method in class com.hazelcast.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).

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

Specifies if the source's state should be kept or discarded during reconnect attempts to the database.

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

Snapshot mode that will be used by the connector.

setSslCertificateFile(String) - Method in class com.hazelcast.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.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.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.jet.cdc.postgres.PostgresCdcSources.Builder

Specifies whether to use an encrypted connection to the database.

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

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

setTableBlacklist(String...) - Method in class com.hazelcast.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.

setTableWhitelist(String...) - Method in class com.hazelcast.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.

V

valueOf(String) - Static method in enum class com.hazelcast.jet.cdc.postgres.PostgresCdcSources.PostgresSnapshotMode

Returns the enum constant of this class with the specified name.

values() - Static method in enum class com.hazelcast.jet.cdc.postgres.PostgresCdcSources.PostgresSnapshotMode

Returns an array containing the constants of this enum class, in the order they are declared.

A B C I N P S V
All Classes and Interfaces|All Packages