Uses of Interface
com.hazelcast.enterprise.jet.cdc.RecordMappingFunction
Package
Description
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.
MySQL-specific CDC API.
PostgreSQL-specific CDC API.
-
Uses of RecordMappingFunction in com.hazelcast.enterprise.jet.cdc
Modifier and TypeFieldDescriptionprotected RecordMappingFunction<T>
DebeziumCdcSources.Builder.recordMappingFunction
Modifier and TypeMethodDescription<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.ModifierConstructorDescriptionprotected
Builder
(String name, String connectorClass, RecordMappingFunction<T> recordMappingFunction) -
Uses of RecordMappingFunction in com.hazelcast.enterprise.jet.cdc.mysql
Modifier and TypeMethodDescription<T_NEW> MySqlCdcSources.Builder<T_NEW>
MySqlCdcSources.Builder.customMapping
(RecordMappingFunction<T_NEW> recordMappingFunction) Sets the return type of the source to user defined#T_NEW
type. -
Uses of RecordMappingFunction in com.hazelcast.enterprise.jet.cdc.postgres
Modifier and TypeMethodDescription<T_NEW> PostgresCdcSources.Builder<T_NEW>
PostgresCdcSources.Builder.customMapping
(RecordMappingFunction<T_NEW> recordMappingFunction) Sets the return type of the source to user defined#T_NEW
type.