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

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.