Uses of Class
com.hazelcast.jet.cdc.mysql.MySqlCdcSources.Builder
Package | Description |
---|---|
com.hazelcast.jet.cdc.mysql |
Contains connectors for change data capture events from MySQL
databases.
|
-
Uses of MySqlCdcSources.Builder in com.hazelcast.jet.cdc.mysql
Methods in com.hazelcast.jet.cdc.mysql that return MySqlCdcSources.Builder Modifier and Type Method Description static MySqlCdcSources.Builder
MySqlCdcSources. mysql(String name)
Creates a CDC source that streams change data from a MySQL database to Hazelcast Jet.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setClusterName(String cluster)
Logical name that identifies and provides a namespace for the particular database server/cluster being monitored.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setColumnBlacklist(String... columnNameRegExps)
Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setCustomProperty(String key, String value)
Can be used to set any property not explicitly covered by other methods or to override internal properties.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setDatabaseAddress(String address)
IP address or hostname of the database server, has to be specified.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setDatabaseBlacklist(String... dbNameRegExps)
Optional regular expressions that match database names to be excluded from monitoring; any database name not included in the blacklist will be monitored.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setDatabaseClientId(int clientId)
A numeric ID of this database client, which must be unique across all currently-running database processes in the MySQL cluster.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setDatabasePassword(String password)
Database user password for connecting to the database server.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setDatabasePort(int port)
Optional port number of the database server, if unspecified defaults to the database specific default port (3306).MySqlCdcSources.Builder
MySqlCdcSources.Builder. setDatabaseUser(String user)
Database user for connecting to the database server.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setDatabaseWhitelist(String... dbNameRegExps)
Optional regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded from monitoring.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setReconnectBehavior(RetryStrategy retryStrategy)
Specifies how the source should behave when it detects that the backing database has been shut down (read class javadoc for details and special cases).MySqlCdcSources.Builder
MySqlCdcSources.Builder. setShouldStateBeResetOnReconnect(boolean reset)
Specifies if the source's state should be kept or discarded during reconnect attempts to the database.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setSslKeystoreFile(String file)
Specifies the (path to the) Java keystore file containing the database client certificate and private key.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setSslKeystorePassword(String password)
Password to access the private key from any specified keystore files.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setSslMode(String mode)
Specifies whether to use an encrypted connection to the database.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setSslTruststoreFile(String file)
Specifies the (path to the) Java truststore file containing the collection of trusted CA certificates.MySqlCdcSources.Builder
MySqlCdcSources.Builder. setSslTruststorePassword(String password)
Password to unlock any specified truststore.MySqlCdcSources.Builder
MySqlCdcSources.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.MySqlCdcSources.Builder
MySqlCdcSources.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.