Class TruncateTableEvent
- java.lang.Object
-
- org.apache.flink.cdc.common.event.TruncateTableEvent
-
- All Implemented Interfaces:
Serializable,ChangeEvent,Event,SchemaChangeEvent
@PublicEvolving public class TruncateTableEvent extends Object implements SchemaChangeEvent
ASchemaChangeEventthat represents anTRUNCATE TABLEDDL. this will be sent byDataSourcebefore allDataChangeEventwith the same tableId.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description TruncateTableEvent(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
-
TruncateTableEvent
public TruncateTableEvent(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
-
-