org.apache.flink.cdc.common.event

类 CreateTableEvent

java.lang.Object

org.apache.flink.cdc.common.event.CreateTableEvent

所有已实现的接口:

Serializable, ChangeEvent, Event, SchemaChangeEvent

@PublicEvolving
public class CreateTableEvent
extends Object
implements SchemaChangeEvent

A SchemaChangeEvent that represents an CREATE TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
CreateTableEvent(TableId tableId, Schema schema)

方法概要

限定符和类型	方法和说明
SchemaChangeEvent	copy(TableId newTableId) Creates a copy of SchemaChangeEvent with new TableId.
boolean	equals(Object o)
Schema	getSchema() Returns the table schema.
SchemaChangeEventType	getType() Returns its SchemaChangeEventType.
int	hashCode()
TableId	tableId() Describes the database table corresponding to the occurrence of a change event.
String	toString()

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

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

构造器详细资料

CreateTableEvent

public CreateTableEvent(TableId tableId,
                        Schema schema)

方法详细资料

getSchema

public Schema getSchema()

Returns the table schema.

equals

public boolean equals(Object o)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

toString

public String toString()

覆盖:

toString 在类中 Object

tableId

public TableId tableId()

从接口复制的说明: ChangeEvent

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

指定者:

tableId 在接口中 ChangeEvent

getType

public SchemaChangeEventType getType()

从接口复制的说明: SchemaChangeEvent

Returns its SchemaChangeEventType.

指定者:

getType 在接口中 SchemaChangeEvent

copy

public SchemaChangeEvent copy(TableId newTableId)

从接口复制的说明: SchemaChangeEvent

Creates a copy of SchemaChangeEvent with new TableId.

指定者:

copy 在接口中 SchemaChangeEvent