Index (hazelcast-enterprise-cdc-debezium 5.7.0-SNAPSHOT API)

A B C D E G I J K M N O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form

A

ALWAYS - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode: Always perform a snapshot when starting.

B

build() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Returns the CDC source based on the properties set.
Builder(String, String, RecordMappingFunction<T>) - Constructor for class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder

C

CdcSinks - Class in com.hazelcast.enterprise.jet.cdc: Contains factory methods for change data capture specific pipeline sinks.
changeRecord() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets the return type of the source to ChangeRecord.
ChangeRecord - Interface in com.hazelcast.enterprise.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.enterprise.jet.cdc.Operation: Returns the Debezium operation code as String.
com.hazelcast.enterprise.jet.cdc - package com.hazelcast.enterprise.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.
config - Variable in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
CONFIGURATION_BASED - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode: Allows control over snapshots by setting connectors properties prefixed with 'snapshot.mode.configuration.based'.
customMapping(RecordMappingFunction<T_NEW>) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets the return type of the source to user defined #T_NEW type.

D

database() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord: Returns the name of the database containing the record's table.
debezium(String, Class<?>) - Static method in class com.hazelcast.enterprise.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.enterprise.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.enterprise.jet.cdc: Contains factory methods for creating Change Data Capture (CDC) sources.
DebeziumCdcSources.Builder<T> - Class in com.hazelcast.enterprise.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.enterprise.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.enterprise.jet.cdc.DebeziumCdcSources: Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
DebeziumSnapshotMode - Enum Class in com.hazelcast.enterprise.jet.cdc: Possible Debezium snapshot modes, that does not require additional mandatory parameters to be set.
DELETE - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.Operation: Record deletion, sourced from the DB changelog.

E

engineBuilderSupplier - Variable in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder

G

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

I

init(Properties, ClassLoader) - Method in interface com.hazelcast.enterprise.jet.cdc.RecordMappingFunction: Initializes this mapping function
INITIAL - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode: Perform a snapshot only upon initial startup of a connector.
INITIAL_ONLY - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode: Perform a snapshot and then stop before attempting to receive any logical changes.
INSERT - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.Operation: Record insertion, sourced from the DB changelog.

J

json() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets the return type of the source to Map.Entry with key and value being SourceRecord's key and value, parsed to json string.

K

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

M

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

N

newValue() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord: Returns the new value of the record.
NO_DATA - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode: Never perform a snapshot and only receive logical changes.
nonNullValue() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord: Returns the value part of the CDC event.

O

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

P

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

R

recordMappingFunction - Variable in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
RecordMappingFunction<R> - Interface in com.hazelcast.enterprise.jet.cdc: Function that maps given SourceRecord to some particular R type.
RecordPart - Interface in com.hazelcast.enterprise.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.enterprise.jet.cdc.CdcSinks: 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.

S

schema() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord: Returns the name of the schema containing the record's table.
sequence(Map<String, ?>) - Method in interface com.hazelcast.enterprise.jet.cdc.SequenceExtractor
SEQUENCE_CACHE_EXPIRATION_SECONDS - Static variable in class com.hazelcast.enterprise.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).
SequenceExtractor - Interface in com.hazelcast.enterprise.jet.cdc: Utility that takes Debezium event headers and computes a sequence number we can use to ensure the ordering of ChangeRecord items.
sequenceSource() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord: Specifies the source descriptor of the record's sequence.
sequenceValue() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord: Specifies the numeric value part of the record's source sequence.
setDatabaseExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Optional regular expressions that match databases to be excluded from monitoring; any table not included in the exclude list will be monitored.
setDatabaseIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Optional regular expressions that match databases to be monitored; any database not included in the include list will be excluded from monitoring.
setProperty(String, boolean) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets a source property.
setProperty(String, int) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets a source property.
setProperty(String, long) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets a source property.
setProperty(String, String) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets a source property.
setTableExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Optional regular expressions that match fully-qualified table identifiers for tables to be excluded from monitoring; any table not included in the exclude list will be monitored.
setTableIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Optional regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whitelist will be excluded from monitoring.
source() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord: Returns full source field of input SourceRecord.
source(Map<String, ?>, Map<String, ?>) - Method in interface com.hazelcast.enterprise.jet.cdc.SequenceExtractor
SYNC - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.Operation: Just like Operation.INSERT, but coming from the initial DB snapshot (as opposed to the change log).

T

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

U

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

V

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

W

WHEN_NEEDED - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode: Perform a snapshot when it is needed.
withAsyncEngine() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Changes the engine used to async embedded engine.
withDefaultEngine() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Changes the engine used to default embedded engine.
withErrorMaxRetries(int) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets the maximum retry count in case of errors.
withSequenceExtractor(Class<? extends SequenceExtractor>) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder: Sets the SequenceExtractor class property.

A B C D E G I J K M N O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form