Uses of Class
com.hazelcast.jet.cdc.ParsingException

Packages that use 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 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.