Uses of Interface
com.hazelcast.enterprise.jet.cdc.ChangeRecord

Packages that use ChangeRecord

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 ChangeRecord in com.hazelcast.enterprise.jet.cdc

Methods in com.hazelcast.enterprise.jet.cdc that return types with arguments of type ChangeRecord

Modifier and Type	Method	Description
DebeziumCdcSources.Builder<ChangeRecord>	DebeziumCdcSources.Builder.changeRecord()	Sets the return type of the source to ChangeRecord.
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 <K, V> com.hazelcast.jet.pipeline.Sink<ChangeRecord>	CdcSinks.map(com.hazelcast.map.IMap<? super K,? super V> map, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends K> keyFn, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends V> valueFn)	Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an IMap.
static <K, V> com.hazelcast.jet.pipeline.Sink<ChangeRecord>	CdcSinks.map(String mapName, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends K> keyFn, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends V> valueFn)	Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an IMap.
static <K, V> com.hazelcast.jet.pipeline.Sink<ChangeRecord>	CdcSinks.remoteMap(String mapName, com.hazelcast.client.config.ClientConfig clientConfig, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends K> keyFn, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends V> valueFn)	Returns a sink equivalent to CdcSinks.map(java.lang.String, com.hazelcast.function.FunctionEx<? super com.hazelcast.enterprise.jet.cdc.ChangeRecord, ? extends K>, com.hazelcast.function.FunctionEx<? super com.hazelcast.enterprise.jet.cdc.ChangeRecord, ? extends V>), but for a map in a remote Hazelcast cluster identified by the supplied ClientConfig.

Method parameters in com.hazelcast.enterprise.jet.cdc with type arguments of type ChangeRecord

Modifier and Type	Method	Description
static <K, V> com.hazelcast.jet.pipeline.Sink<ChangeRecord>	CdcSinks.map(com.hazelcast.map.IMap<? super K,? super V> map, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends K> keyFn, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends V> valueFn)	Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an IMap.
static <K, V> com.hazelcast.jet.pipeline.Sink<ChangeRecord>	CdcSinks.map(String mapName, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends K> keyFn, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends V> valueFn)	Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an IMap.
static <K, V> com.hazelcast.jet.pipeline.Sink<ChangeRecord>	CdcSinks.remoteMap(String mapName, com.hazelcast.client.config.ClientConfig clientConfig, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends K> keyFn, com.hazelcast.function.FunctionEx<? super ChangeRecord,? extends V> valueFn)	Returns a sink equivalent to CdcSinks.map(java.lang.String, com.hazelcast.function.FunctionEx<? super com.hazelcast.enterprise.jet.cdc.ChangeRecord, ? extends K>, com.hazelcast.function.FunctionEx<? super com.hazelcast.enterprise.jet.cdc.ChangeRecord, ? extends V>), but for a map in a remote Hazelcast cluster identified by the supplied ClientConfig.

Uses of ChangeRecord in com.hazelcast.enterprise.jet.cdc.mysql

Methods in com.hazelcast.enterprise.jet.cdc.mysql that return types with arguments of type ChangeRecord

Modifier and Type	Method	Description
MySqlCdcSources.Builder<ChangeRecord>	MySqlCdcSources.Builder.changeRecord()	Sets the return type of the source to ChangeRecord.
static MySqlCdcSources.Builder<ChangeRecord>	MySqlCdcSources.mysql(String name)	Creates a CDC source that streams change data from a MySQL database to Hazelcast Jet.

Uses of ChangeRecord in com.hazelcast.enterprise.jet.cdc.postgres

Methods in com.hazelcast.enterprise.jet.cdc.postgres that return types with arguments of type ChangeRecord

Modifier and Type	Method	Description
PostgresCdcSources.Builder<ChangeRecord>	PostgresCdcSources.Builder.changeRecord()	Sets the return type of the source to ChangeRecord.
static PostgresCdcSources.Builder<ChangeRecord>	PostgresCdcSources.postgres(String name)	Creates a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.