org.apache.flink.cdc.common.event

接口 SchemaChangeEventWithPreSchema

所有超级接口:

ChangeEvent, Event, SchemaChangeEvent, Serializable

所有已知实现类:

AlterColumnTypeEvent

@PublicEvolving
public interface SchemaChangeEventWithPreSchema
extends SchemaChangeEvent

A SchemaChangeEvent that supports appending schema before change event.

方法概要

限定符和类型	方法和说明
void	fillPreSchema(Schema oldSchema) Append schema before change info to this event.
boolean	hasPreSchema() Describes if this event already has schema before change info.
default boolean	trimRedundantChanges() Check if this event contains redundant schema change request only.

从接口继承的方法 org.apache.flink.cdc.common.event.SchemaChangeEvent

copy, getType

从接口继承的方法 org.apache.flink.cdc.common.event.ChangeEvent

tableId

方法详细资料

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.