Uses of Class
com.hazelcast.jet.cdc.ParsingException
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.
|
-
Uses of ParsingException in com.hazelcast.jet.cdc
Methods in com.hazelcast.jet.cdc that throw ParsingException Modifier and Type Method 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 correspondingOperation
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 aMap
.<T> T
RecordPart. toObject(Class<T> clazz)
Maps the entire element to an instance of the specified class.