Index

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

B

build() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

Returns the source based on the properties set so far.

C

changeRecord() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

Sets the return type of the source to ChangeRecord.

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

MySQL-specific CDC API.

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

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

J

json() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.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.

M

mysql(String) - Static method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources

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

MySqlCdcSources - Class in com.hazelcast.enterprise.jet.cdc.mysql

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

MySqlCdcSources.Builder<T> - Class in com.hazelcast.enterprise.jet.cdc.mysql

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

MySqlSequenceExtractor - Class in com.hazelcast.enterprise.jet.cdc.mysql

MySqlSequenceExtractor() - Constructor for class com.hazelcast.enterprise.jet.cdc.mysql.MySqlSequenceExtractor

S

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

setColumnIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.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.mysql.MySqlCdcSources.Builder

Custom snapshotter that will be used by the connector.

setDatabaseAddress(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

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

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

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

setDatabaseClientId(int) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

A numeric ID of this database client, which must be unique across all currently-running database processes in the MySQL cluster.

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

Database user and password for connecting to the database server.

setDatabaseExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.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.mysql.MySqlCdcSources.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.mysql.MySqlCdcSources.Builder

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

setDatabasePassword(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

Database user password for connecting to the database server.

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

Database user for connecting to the database server.

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

Sets a source property.

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

Sets a source property.

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

Sets a source property.

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

Sets a source property.

setSchemaExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.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.mysql.MySqlCdcSources.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.mysql.MySqlCdcSources.Builder

Snapshot mode that will be used by the connector.

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

Specifies whether to use an encrypted connection to the database.

setSslRootCertificateFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

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

setTableExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.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.mysql.MySqlCdcSources.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.mysql.MySqlSequenceExtractor

W

withAsyncEngine() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

Changes the engine used to async embedded engine.

withDefaultEngine() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

Changes the engine used to default embedded engine.

withErrorMaxRetries(int) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder

Sets the maximum retry count in case of errors.

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

Sets the SequenceExtractor class property.

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