Uses of Interface
com.hazelcast.jet.cdc.ChangeRecord
Package | Description |
---|---|
com.hazelcast.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.jet.cdc.mysql |
Contains connectors for change data capture events from MySQL
databases.
|
com.hazelcast.jet.cdc.postgres |
Contains connectors for change data capture events from PostgreSQL
databases.
|
-
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, 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 anIMap
.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 anIMap
.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 toCdcSinks.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 suppliedClientConfig
.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 anIMap
.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 anIMap
.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 toCdcSinks.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 suppliedClientConfig
. -
Uses of ChangeRecord in com.hazelcast.jet.cdc.mysql
Methods in com.hazelcast.jet.cdc.mysql that return types with arguments of type ChangeRecord Modifier and Type Method Description StreamSource<ChangeRecord>
MySqlCdcSources.Builder. build()
Returns the source based on the properties set so far. -
Uses of ChangeRecord in com.hazelcast.jet.cdc.postgres
Methods in com.hazelcast.jet.cdc.postgres that return types with arguments of type ChangeRecord Modifier and Type Method Description StreamSource<ChangeRecord>
PostgresCdcSources.Builder. build()
Returns the source based on the properties set so far.