Class DropColumnEvent
- java.lang.Object
-
- org.apache.flink.cdc.common.event.DropColumnEvent
-
- All Implemented Interfaces:
Serializable,ChangeEvent,Event,SchemaChangeEvent
@PublicEvolving public class DropColumnEvent extends Object implements SchemaChangeEvent
ASchemaChangeEventthat represents anDROP COLUMNDDL, which may contain the lenient column type changes.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description DropColumnEvent(TableId tableId, List<String> droppedColumnNames)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SchemaChangeEventcopy(TableId newTableId)Creates a copy ofSchemaChangeEventwith newTableId.booleanequals(Object o)List<String>getDroppedColumnNames()SchemaChangeEventTypegetType()Returns itsSchemaChangeEventType.inthashCode()TableIdtableId()Describes the database table corresponding to the occurrence of a change event.StringtoString()
-
-
-
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
-
-