com.ververica.cdc.debezium.internal

Class SchemaRecord

java.lang.Object

com.ververica.cdc.debezium.internal.SchemaRecord

public class SchemaRecord
extends Object

The Record represents a schema change event, it contains either one HistoryRecord or TableChanges.TableChange.

The HistoryRecord will be used by FlinkDatabaseHistory which keeps full history of table change events for all tables, the TableChanges.TableChange will be used by FlinkDatabaseSchemaHistory which keeps the latest table change for each table.

Constructor Summary

Constructors

Constructor and Description
SchemaRecord(io.debezium.document.Document document)
SchemaRecord(io.debezium.relational.history.HistoryRecord historyRecord)

Method Summary

Modifier and Type	Method and Description
io.debezium.relational.history.HistoryRecord	getHistoryRecord()
io.debezium.document.Document	getTableChangeDoc()
boolean	isHistoryRecord()
boolean	isTableChangeRecord()
io.debezium.document.Document	toDocument()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SchemaRecord

public SchemaRecord(io.debezium.relational.history.HistoryRecord historyRecord)

SchemaRecord

public SchemaRecord(io.debezium.document.Document document)

Method Detail

getHistoryRecord

@Nullable
public io.debezium.relational.history.HistoryRecord getHistoryRecord()

getTableChangeDoc

@Nullable
public io.debezium.document.Document getTableChangeDoc()

isHistoryRecord

public boolean isHistoryRecord()

isTableChangeRecord

public boolean isTableChangeRecord()

toDocument

public io.debezium.document.Document toDocument()

toString

public String toString()

Overrides:

toString in class Object