Class CreateTableEvent
- java.lang.Object
-
- org.apache.flink.cdc.common.event.CreateTableEvent
-
- All Implemented Interfaces:
Serializable,ChangeEvent,Event,SchemaChangeEvent
@PublicEvolving public class CreateTableEvent extends Object implements SchemaChangeEvent
ASchemaChangeEventthat represents anCREATE TABLEDDL. this will be sent byDataSourcebefore allDataChangeEventwith the same tableId- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CreateTableEvent(TableId tableId, Schema schema)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SchemaChangeEventcopy(TableId newTableId)Creates a copy ofSchemaChangeEventwith newTableId.booleanequals(Object o)SchemagetSchema()Returns the table schema.SchemaChangeEventTypegetType()Returns itsSchemaChangeEventType.inthashCode()TableIdtableId()Describes the database table corresponding to the occurrence of a change event.StringtoString()
-
-
-
Method Detail
-
getSchema
public Schema getSchema()
Returns the table schema.
-
tableId
public TableId tableId()
Description copied from interface:ChangeEventDescribes the database table corresponding to the occurrence of a change event.- Specified by:
tableIdin interfaceChangeEvent
-
getType
public SchemaChangeEventType getType()
Description copied from interface:SchemaChangeEventReturns itsSchemaChangeEventType.- Specified by:
getTypein interfaceSchemaChangeEvent
-
copy
public SchemaChangeEvent copy(TableId newTableId)
Description copied from interface:SchemaChangeEventCreates a copy ofSchemaChangeEventwith newTableId.- Specified by:
copyin interfaceSchemaChangeEvent
-
-