Uses of Class
com.hazelcast.jet.cdc.mysql.MySqlCdcSources.Builder

Packages that use 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 and 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.