Uses of Class
com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder

Packages that use DebeziumCdcSources.Builder

Package	Description
com.hazelcast.enterprise.jet.cdc	Contains source/sink connectors that deal with Change Data Capture (CDC) events from various databases as well as a generic connector for Debezium CDC sources.
com.hazelcast.enterprise.jet.cdc.mysql	MySQL-specific CDC API.
com.hazelcast.enterprise.jet.cdc.postgres	PostgreSQL-specific CDC API.

Uses of DebeziumCdcSources.Builder in com.hazelcast.enterprise.jet.cdc

Methods in com.hazelcast.enterprise.jet.cdc that return DebeziumCdcSources.Builder

Modifier and Type	Method	Description
DebeziumCdcSources.Builder<ChangeRecord>	DebeziumCdcSources.Builder.changeRecord()	Sets the return type of the source to ChangeRecord.
<T_NEW> DebeziumCdcSources.Builder<T_NEW>	DebeziumCdcSources.Builder.customMapping(RecordMappingFunction<T_NEW> recordMappingFunction)	Sets the return type of the source to user defined #T_NEW type.
static DebeziumCdcSources.Builder<ChangeRecord>	DebeziumCdcSources.debezium(String name, Class<?> connectorClass)	Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
static DebeziumCdcSources.Builder<ChangeRecord>	DebeziumCdcSources.debezium(String name, String connectorClass)	Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
static DebeziumCdcSources.Builder<Map.Entry<String,String>>	DebeziumCdcSources.debeziumJson(String name, Class<?> connectorClass)	Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
static DebeziumCdcSources.Builder<Map.Entry<String,String>>	DebeziumCdcSources.debeziumJson(String name, String connectorClass)	Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
DebeziumCdcSources.Builder<Map.Entry<String,String>>	DebeziumCdcSources.Builder.json()	Sets the return type of the source to Map.Entry with key and value being SourceRecord's key and value, parsed to json string.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.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.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.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.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.Builder.setProperty(String key, boolean value)	Sets a source property.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.Builder.setProperty(String key, int value)	Sets a source property.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.Builder.setProperty(String key, long value)	Sets a source property.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.Builder.setProperty(String key, String value)	Sets a source property.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.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 exclude list will be monitored.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.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.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.Builder.withAsyncEngine()	Changes the engine used to async embedded engine.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.Builder.withDefaultEngine()	Changes the engine used to default embedded engine.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.Builder.withErrorMaxRetries(int errorRetryCount)	Sets the maximum retry count in case of errors.
DebeziumCdcSources.Builder<T>	DebeziumCdcSources.Builder.withSequenceExtractor(Class<? extends SequenceExtractor> sequenceExtractorClass)	Sets the SequenceExtractor class property.

Uses of DebeziumCdcSources.Builder in com.hazelcast.enterprise.jet.cdc.mysql

Subclasses of DebeziumCdcSources.Builder in com.hazelcast.enterprise.jet.cdc.mysql

Modifier and Type	Class	Description
static final class	MySqlCdcSources.Builder<T>	Builder for configuring a CDC source that streams change data from a MySQL database to Hazelcast Jet.

Uses of DebeziumCdcSources.Builder in com.hazelcast.enterprise.jet.cdc.postgres

Subclasses of DebeziumCdcSources.Builder in com.hazelcast.enterprise.jet.cdc.postgres

Modifier and Type	Class	Description
static final class	PostgresCdcSources.Builder<T>	Builder for configuring a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.