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.
|
Modifier and Type | Method and Description |
---|---|
String |
ChangeRecord.database()
Returns the name of the database containing the record's table.
|
static Operation |
Operation.get(String opcode)
Parses the string present in a CDC message into the corresponding
Operation enum member. |
Operation |
ChangeRecord.operation()
Returns the type of change this record describes (insert, delete or
update).
|
String |
ChangeRecord.schema()
Returns the name of the schema containing the record's table.
|
String |
ChangeRecord.table()
Returns the name of the table this record is part of.
|
long |
ChangeRecord.timestamp()
Specifies the moment when the change event occurred in the database.
|
Map<String,Object> |
RecordPart.toMap()
Presents a parsed form of the underlying JSON message as a
Map . |
<T> T |
RecordPart.toObject(Class<T> clazz)
Maps the entire element to an instance of the specified class.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.