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

Uses of ChangeRecord in com.hazelcast.jet.cdc

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

Modifier and Type	Method	Description
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> Sink<ChangeRecord>	CdcSinks.map(IMap<? super K,? super V> map, FunctionEx<? super ChangeRecord,? extends K> keyFn, 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> Sink<ChangeRecord>	CdcSinks.map(String mapName, FunctionEx<? super ChangeRecord,? extends K> keyFn, 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> Sink<ChangeRecord>	CdcSinks.remoteMap(String mapName, ClientConfig clientConfig, FunctionEx<? super ChangeRecord,? extends K> keyFn, FunctionEx<? super ChangeRecord,? extends V> valueFn)	Returns a sink equivalent to CdcSinks.map(java.lang.String, com.hazelcast.function.FunctionEx<? super com.hazelcast.jet.cdc.ChangeRecord, ? extends K>, com.hazelcast.function.FunctionEx<? super com.hazelcast.jet.cdc.ChangeRecord, ? extends V>), but for a map in a remote Hazelcast cluster identified by the supplied ClientConfig.

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

Modifier and Type	Method	Description
static <K, V> Sink<ChangeRecord>	CdcSinks.map(IMap<? super K,? super V> map, FunctionEx<? super ChangeRecord,? extends K> keyFn, 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> Sink<ChangeRecord>	CdcSinks.map(String mapName, FunctionEx<? super ChangeRecord,? extends K> keyFn, 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> Sink<ChangeRecord>	CdcSinks.remoteMap(String mapName, ClientConfig clientConfig, FunctionEx<? super ChangeRecord,? extends K> keyFn, FunctionEx<? super ChangeRecord,? extends V> valueFn)	Returns a sink equivalent to CdcSinks.map(java.lang.String, com.hazelcast.function.FunctionEx<? super com.hazelcast.jet.cdc.ChangeRecord, ? extends K>, com.hazelcast.function.FunctionEx<? super com.hazelcast.jet.cdc.ChangeRecord, ? extends V>), but for a map in a remote Hazelcast cluster identified by the supplied ClientConfig.