Class DropTableEvent
- java.lang.Object
-
- org.apache.flink.cdc.common.event.DropTableEvent
-
- All Implemented Interfaces:
Serializable,ChangeEvent,Event,SchemaChangeEvent
@PublicEvolving public class DropTableEvent extends Object implements SchemaChangeEvent
ASchemaChangeEventthat represents anDROP TABLEDDL. this will be sent byDataSourcebefore allDataChangeEventwith the same tableId.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description DropTableEvent(TableId tableId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SchemaChangeEventcopy(TableId newTableId)Creates a copy ofSchemaChangeEventwith newTableId.booleanequals(Object o)SchemaChangeEventTypegetType()Returns itsSchemaChangeEventType.inthashCode()TableIdtableId()Describes the database table corresponding to the occurrence of a change event.StringtoString()
-
-
-
Constructor Detail
-
DropTableEvent
public DropTableEvent(TableId tableId)
-
-
Method Detail
-
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
-
-