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

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.