Interface SchemaChangeEventWithPreSchema
-
- All Superinterfaces:
ChangeEvent,Event,SchemaChangeEvent,Serializable
- All Known Implementing Classes:
AlterColumnTypeEvent
@PublicEvolving public interface SchemaChangeEventWithPreSchema extends SchemaChangeEvent
ASchemaChangeEventthat supports appending schema before change event.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description voidfillPreSchema(Schema oldSchema)Append schema before change info to this event.booleanhasPreSchema()Describes if this event already has schema before change info.default booleantrimRedundantChanges()Check if this event contains redundant schema change request only.-
Methods inherited from interface org.apache.flink.cdc.common.event.ChangeEvent
tableId
-
Methods inherited from interface org.apache.flink.cdc.common.event.SchemaChangeEvent
copy, getType
-
-
-
-
Method Detail
-
hasPreSchema
boolean hasPreSchema()
Describes if this event already has schema before change info.
-
fillPreSchema
void fillPreSchema(Schema oldSchema)
Append schema before change info to this event.
-
trimRedundantChanges
default boolean trimRedundantChanges()
Check if this event contains redundant schema change request only.
-
-