Uses of Class
com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Packages that use MySqlCdcSources.Builder
-
Uses of MySqlCdcSources.Builder in com.hazelcast.enterprise.jet.cdc.mysql
Methods in com.hazelcast.enterprise.jet.cdc.mysql that return MySqlCdcSources.BuilderModifier and TypeMethodDescriptionMySqlCdcSources.Builder.changeRecord()Sets the return type of the source toChangeRecord.<T_NEW> MySqlCdcSources.Builder<T_NEW>MySqlCdcSources.Builder.customMapping(RecordMappingFunction<T_NEW> recordMappingFunction) Sets the return type of the source to user defined#T_NEWtype.MySqlCdcSources.Builder.json()Sets the return type of the source toMap.Entrywith key and value beingSourceRecord's key and value, parsed to json string.static MySqlCdcSources.Builder<ChangeRecord>Creates a CDC source that streams change data from a MySQL database to Hazelcast Jet.MySqlCdcSources.Builder.setColumnIncludeList(String... columnNameRegExps) Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.MySqlCdcSources.Builder.setCustomSnapshotter(Class<?> snapshotterClass) Custom snapshotter that will be used by the connector.MySqlCdcSources.Builder.setDatabaseAddress(String address) IP address or hostname of the database server, has to be specified.MySqlCdcSources.Builder.setDatabaseAddress(String address, int port) IP address or hostname and the port of the database server, has to be specified.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.setDatabaseCredentials(String user, String password) Database user and password for connecting to the database server.MySqlCdcSources.Builder.setDatabaseExcludeList(String... databaseNameRegExps) Optional regular expressions that match databases to be excluded from monitoring; any table not included in the exclude list will be monitored.MySqlCdcSources.Builder.setDatabaseIncludeList(String... databaseNameRegExps) Optional regular expressions that match databases to be monitored; any database not included in the include list will be excluded from monitoring.MySqlCdcSources.Builder.setDatabaseName(String dbName) The name of the MySQL database from which to stream the changes.MySqlCdcSources.Builder.setDatabasePassword(String password) Database user password for connecting to the database server.MySqlCdcSources.Builder.setDatabasePort(int port) Optional port number of the database server, if unspecified defaults to the database specific default port (5432).MySqlCdcSources.Builder.setDatabaseUser(String user) Database user for connecting to the database server.MySqlCdcSources.Builder.setProperty(String key, boolean value) Sets a source property.MySqlCdcSources.Builder.setProperty(String key, int value) Sets a source property.MySqlCdcSources.Builder.setProperty(String key, long value) Sets a source property.MySqlCdcSources.Builder.setProperty(String key, String value) Sets a source property.MySqlCdcSources.Builder.setSchemaExcludeList(String... schemaNameRegExps) Optional regular expressions that match schema names to be excluded from monitoring ("schema" is used here to denote logical groups of tables).MySqlCdcSources.Builder.setSchemaIncludeList(String... schemaNameRegExps) Optional regular expressions that match schema names to be monitored ("schema" is used here to denote logical groups of tables).MySqlCdcSources.Builder.setSnapshotMode(DebeziumSnapshotMode snapshotMode) Snapshot mode that will be used by the connector.MySqlCdcSources.Builder.setSslCertificateFile(String file) Specifies the (path to the) file containing the SSL Certificate for the database client.MySqlCdcSources.Builder.setSslKeyFile(String file) Specifies the (path to the) file containing the SSL private key of the database client.MySqlCdcSources.Builder.setSslKeyFilePassword(String password) Specifies the password to be used to access the SSL key file, if specified.MySqlCdcSources.Builder.setSslMode(String mode) Specifies whether to use an encrypted connection to the database.MySqlCdcSources.Builder.setSslRootCertificateFile(String file) Specifies the file containing SSL certificate authority (CA) certificate(s).MySqlCdcSources.Builder.setTableExcludeList(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.setTableIncludeList(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.MySqlCdcSources.Builder.withAsyncEngine()Changes the engine used to async embedded engine.MySqlCdcSources.Builder.withDefaultEngine()Changes the engine used to default embedded engine.MySqlCdcSources.Builder.withErrorMaxRetries(int errorRetryCount) Sets the maximum retry count in case of errors.MySqlCdcSources.Builder.withSequenceExtractor(Class<? extends SequenceExtractor> sequenceExtractorClass) Sets theSequenceExtractorclass property.