org.apache.flink.cdc.common.event

类 DataChangeEvent

java.lang.Object

org.apache.flink.cdc.common.event.DataChangeEvent

所有已实现的接口:

Serializable, ChangeEvent, Event

@PublicEvolving
public class DataChangeEvent
extends Object
implements ChangeEvent, Serializable

Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.

另请参阅:

序列化表格

方法概要

限定符和类型	方法和说明
RecordData	after()
RecordData	before()
static DataChangeEvent	deleteEvent(TableId tableId, RecordData before) Creates a DataChangeEvent instance that describes the delete event.
static DataChangeEvent	deleteEvent(TableId tableId, RecordData before, Map<String,String> meta) Creates a DataChangeEvent instance that describes the delete event with meta info.
String	describeMeta() Creates a string to describe the information of meta.
boolean	equals(Object o)
int	hashCode()
static DataChangeEvent	insertEvent(TableId tableId, RecordData after) Creates a DataChangeEvent instance that describes the insert event.
static DataChangeEvent	insertEvent(TableId tableId, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the insert event with meta info.
Map<String,String>	meta()
OperationType	op()
static DataChangeEvent	projectAfter(DataChangeEvent dataChangeEvent, RecordData projectedAfter) Updates the after of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	projectBefore(DataChangeEvent dataChangeEvent, RecordData projectedBefore) Updates the before of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	replaceEvent(TableId tableId, RecordData after) Creates a DataChangeEvent instance that describes the replace event.
static DataChangeEvent	replaceEvent(TableId tableId, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the replace event with meta info.
static DataChangeEvent	route(DataChangeEvent dataChangeEvent, TableId tableId) Updates the TableId info of current data change event.
TableId	tableId() Describes the database table corresponding to the occurrence of a change event.
String	toString()
static DataChangeEvent	updateEvent(TableId tableId, RecordData before, RecordData after) Creates a DataChangeEvent instance that describes the update event.
static DataChangeEvent	updateEvent(TableId tableId, RecordData before, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the update event with meta info.

从类继承的方法 java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

方法详细资料

tableId

public TableId tableId()

从接口复制的说明: ChangeEvent

Describes the database table corresponding to the occurrence of a change event.

指定者:

tableId 在接口中 ChangeEvent

before

public RecordData before()

after

public RecordData after()

op

public OperationType op()

meta

public Map<String,String> meta()

insertEvent

public static DataChangeEvent insertEvent(TableId tableId,
                                          RecordData after)

Creates a DataChangeEvent instance that describes the insert event.

insertEvent

public static DataChangeEvent insertEvent(TableId tableId,
                                          RecordData after,
                                          Map<String,String> meta)

Creates a DataChangeEvent instance that describes the insert event with meta info.

deleteEvent

public static DataChangeEvent deleteEvent(TableId tableId,
                                          RecordData before)

Creates a DataChangeEvent instance that describes the delete event.

deleteEvent

public static DataChangeEvent deleteEvent(TableId tableId,
                                          RecordData before,
                                          Map<String,String> meta)

Creates a DataChangeEvent instance that describes the delete event with meta info.

updateEvent

public static DataChangeEvent updateEvent(TableId tableId,
                                          RecordData before,
                                          RecordData after)

Creates a DataChangeEvent instance that describes the update event.

updateEvent

public static DataChangeEvent updateEvent(TableId tableId,
                                          RecordData before,
                                          RecordData after,
                                          Map<String,String> meta)

Creates a DataChangeEvent instance that describes the update event with meta info.

replaceEvent

public static DataChangeEvent replaceEvent(TableId tableId,
                                           RecordData after)

Creates a DataChangeEvent instance that describes the replace event.

replaceEvent

public static DataChangeEvent replaceEvent(TableId tableId,
                                           RecordData after,
                                           Map<String,String> meta)

Creates a DataChangeEvent instance that describes the replace event with meta info.

projectBefore

public static DataChangeEvent projectBefore(DataChangeEvent dataChangeEvent,
                                            RecordData projectedBefore)

Updates the before of a DataChangeEvent instance that describes the event with meta info.

projectAfter

public static DataChangeEvent projectAfter(DataChangeEvent dataChangeEvent,
                                           RecordData projectedAfter)

Updates the after of a DataChangeEvent instance that describes the event with meta info.

route

public static DataChangeEvent route(DataChangeEvent dataChangeEvent,
                                    TableId tableId)

Updates the TableId info of current data change event.

equals

public boolean equals(Object o)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

describeMeta

public String describeMeta()

Creates a string to describe the information of meta.

toString

public String toString()

覆盖:

toString 在类中 Object