Index (hazelcast-jet-cdc-debezium 5.4.5 API)

B

build() - Method in class com.hazelcast.jet.cdc.DebeziumCdcSources.Builder: Returns the CDC source based on the properties set.

CdcSinks - Class in com.hazelcast.jet.cdc: Contains factory methods for change data capture specific pipeline sinks.
ChangeRecord - Interface in com.hazelcast.jet.cdc: Information pertaining to a single data change event (insert, delete or update), affecting a single database record.
code() - Method in enum class com.hazelcast.jet.cdc.Operation: Returns the Debezium operation code as String.
com.hazelcast.jet.cdc - package 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.

database() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the name of the database containing the record's table.
debezium(String, Class<?>) - Static method in class com.hazelcast.jet.cdc.DebeziumCdcSources: Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
debezium(String, String) - Static method in class com.hazelcast.jet.cdc.DebeziumCdcSources: Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
DebeziumCdcSources - Class in com.hazelcast.jet.cdc: Contains factory methods for creating Change Data Capture (CDC) sources.
DebeziumCdcSources.Builder<T> - Class in com.hazelcast.jet.cdc: A builder to configure a CDC source that streams the change data from a Debezium-supported database to Hazelcast Jet.
debeziumJson(String, Class<?>) - Static method in class com.hazelcast.jet.cdc.DebeziumCdcSources: Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
debeziumJson(String, String) - Static method in class com.hazelcast.jet.cdc.DebeziumCdcSources: Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
DELETE - Enum constant in enum class com.hazelcast.jet.cdc.Operation: Record deletion, sourced from the DB changelog.

get(String) - Static method in enum class com.hazelcast.jet.cdc.Operation: Parses the string present in a CDC message into the corresponding Operation enum member.

INSERT - Enum constant in enum class com.hazelcast.jet.cdc.Operation: Record insertion, sourced from the DB changelog.

key() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the key part of the CDC event.

map(IMap<? super K, ? super V>, FunctionEx<? super ChangeRecord, ? extends K>, FunctionEx<? super ChangeRecord, ? extends V>) - Static method in class com.hazelcast.jet.cdc.CdcSinks: Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an IMap.
map(String, FunctionEx<? super ChangeRecord, ? extends K>, FunctionEx<? super ChangeRecord, ? extends V>) - Static method in class com.hazelcast.jet.cdc.CdcSinks: Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an IMap.

newValue() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the new value of the record.

oldValue() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the old value of the record.
operation() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the type of change this record describes (insert, delete or update).
Operation - Enum Class in com.hazelcast.jet.cdc: Describes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion.

ParsingException - Exception in com.hazelcast.jet.cdc: Exception to indicate that parsing CDC JSON data has failed irrecoverably.
ParsingException(String) - Constructor for exception com.hazelcast.jet.cdc.ParsingException: Constructs a new exception with the specified detail message.
ParsingException(String, Throwable) - Constructor for exception com.hazelcast.jet.cdc.ParsingException: Constructs a new exception with the specified detail message and Throwable as cause.

RecordPart - Interface in com.hazelcast.jet.cdc: Represents the top-level component of a ChangeRecord, such as the key or the value.
remoteMap(String, ClientConfig, FunctionEx<? super ChangeRecord, ? extends K>, FunctionEx<? super ChangeRecord, ? extends V>) - Static method in class com.hazelcast.jet.cdc.CdcSinks: 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.

schema() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the name of the schema containing the record's table.
SEQUENCE_CACHE_EXPIRATION_SECONDS - Static variable in class com.hazelcast.jet.cdc.CdcSinks: Number of seconds for which the sink will remember the last seen sequence number for an input key (used to detect reordering).
sequenceSource() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Specifies the source descriptor of the record's sequence.
sequenceValue() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Specifies the numeric value part of the record's source sequence.
setProperty(String, String) - Method in class com.hazelcast.jet.cdc.DebeziumCdcSources.Builder: Sets a source property.
SYNC - Enum constant in enum class com.hazelcast.jet.cdc.Operation: Just like INSERT, but coming from the initial DB snapshot (as opposed to the change log).

table() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the name of the table this record is part of.
timestamp() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Specifies the moment when the change event occurred in the database.
toJson() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the raw JSON string from the CDC event underlying this ChangeRecord.
toJson() - Method in interface com.hazelcast.jet.cdc.RecordPart: Returns the raw JSON string that this object wraps.
toMap() - Method in interface com.hazelcast.jet.cdc.RecordPart: Presents a parsed form of the underlying JSON message as a Map.
toObject(Class<T>) - Method in interface com.hazelcast.jet.cdc.RecordPart: Maps the entire element to an instance of the specified class.

UNSPECIFIED - Enum constant in enum class com.hazelcast.jet.cdc.Operation: ChangeRecord doesn't have an operation field, for example heartbeats.
UPDATE - Enum constant in enum class com.hazelcast.jet.cdc.Operation: Record update, sourced from the DB changelog.

value() - Method in interface com.hazelcast.jet.cdc.ChangeRecord: Returns the value part of the CDC event.
valueOf(String) - Static method in enum class com.hazelcast.jet.cdc.Operation: Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.hazelcast.jet.cdc.Operation: Returns an array containing the constants of this enum class, in the order they are declared.