public static class DebeziumEvent.Payload extends Object
Constructor and Description |
---|
Payload(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode source,
org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode before,
org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode after,
String historyRecord,
String op) |
Modifier and Type | Method and Description |
---|---|
org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode |
after() |
org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode |
before() |
Iterator<io.debezium.relational.history.TableChanges.TableChange> |
getTableChanges()
Get table changes in history record.
|
boolean |
hasHistoryRecord() |
String |
historyRecord() |
boolean |
isSchemaChange() |
String |
op() |
org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode |
source() |
public org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode source()
public org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode before()
public org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode after()
public String historyRecord()
public String op()
public boolean isSchemaChange()
public boolean hasHistoryRecord()
public Iterator<io.debezium.relational.history.TableChanges.TableChange> getTableChanges() throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.