Uses of Interface
org.apache.flink.cdc.common.event.SchemaChangeEvent

Packages that use SchemaChangeEvent

Package	Description
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.event.visitor
org.apache.flink.cdc.common.exceptions
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.utils
org.apache.flink.cdc.connectors.doris.sink
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.hudi.sink
org.apache.flink.cdc.connectors.hudi.sink.function
org.apache.flink.cdc.connectors.iceberg.sink
org.apache.flink.cdc.connectors.kafka.sink
org.apache.flink.cdc.connectors.maxcompute
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.source.parser
org.apache.flink.cdc.connectors.oceanbase.sink
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.oracle.source.parser
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.paimon.sink.v2.bucket
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.utils
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.connectors.values
org.apache.flink.cdc.debezium.event
org.apache.flink.cdc.runtime.operators.schema.common
org.apache.flink.cdc.runtime.operators.schema.distributed.event
org.apache.flink.cdc.runtime.operators.schema.regular.event
org.apache.flink.cdc.runtime.serializer.event

Uses of SchemaChangeEvent in org.apache.flink.cdc.common.event

Subinterfaces of SchemaChangeEvent in org.apache.flink.cdc.common.event

Modifier and Type	Interface	Description
interface	SchemaChangeEventWithPreSchema	A SchemaChangeEvent that supports appending schema before change event.

Classes in org.apache.flink.cdc.common.event that implement SchemaChangeEvent

Modifier and Type	Class	Description
class	AddColumnEvent	A SchemaChangeEvent that represents an ADD COLUMN DDL, which may contain the lenient column type changes.
class	AlterColumnTypeEvent	A SchemaChangeEvent that represents an ALTER COLUMN DDL, which may contain the lenient column type changes.
class	AlterTableCommentEvent	A SchemaChangeEvent that represents an ALTER TABLE COMMENT or ALTER TABLE SET COMMENT DDL.
class	CreateTableEvent	A SchemaChangeEvent that represents an CREATE TABLE DDL.
class	DropColumnEvent	A SchemaChangeEvent that represents an DROP COLUMN DDL, which may contain the lenient column type changes.
class	DropTableEvent	A SchemaChangeEvent that represents an DROP TABLE DDL.
class	RenameColumnEvent	A SchemaChangeEvent that represents an RENAME COLUMN DDL, which may contain the lenient column type changes.
class	TruncateTableEvent	A SchemaChangeEvent that represents an TRUNCATE TABLE DDL.

Methods in org.apache.flink.cdc.common.event that return SchemaChangeEvent

Modifier and Type	Method	Description
SchemaChangeEvent	AddColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	AlterColumnTypeEvent.copy(TableId newTableId)
SchemaChangeEvent	AlterTableCommentEvent.copy(TableId newTableId)
SchemaChangeEvent	CreateTableEvent.copy(TableId newTableId)
SchemaChangeEvent	DropColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	DropTableEvent.copy(TableId newTableId)
SchemaChangeEvent	RenameColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	SchemaChangeEvent.copy(TableId newTableId)	Creates a copy of SchemaChangeEvent with new TableId.
SchemaChangeEvent	TruncateTableEvent.copy(TableId newTableId)

Methods in org.apache.flink.cdc.common.event with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
static SchemaChangeEventType	SchemaChangeEventType.ofEvent(SchemaChangeEvent event)

Uses of SchemaChangeEvent in org.apache.flink.cdc.common.event.visitor

Classes in org.apache.flink.cdc.common.event.visitor with type parameters of type SchemaChangeEvent

Modifier and Type	Interface	Description
interface	VisitorHandler<EVT extends SchemaChangeEvent,T,E extends Throwable>	Visitor for TruncateTableEvents.
interface	VoidVisitorHandler<EVT extends SchemaChangeEvent,E extends Throwable>	Visitor for TruncateTableEvents.

Methods in org.apache.flink.cdc.common.event.visitor with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
static <T,E extends Throwable> T	SchemaChangeEventVisitor.visit(SchemaChangeEvent event, VisitorHandler<AddColumnEvent,T,E> addColumnVisitor, VisitorHandler<AlterColumnTypeEvent,T,E> alterColumnTypeEventVisitor, VisitorHandler<CreateTableEvent,T,E> createTableEventVisitor, VisitorHandler<DropColumnEvent,T,E> dropColumnEventVisitor, VisitorHandler<DropTableEvent,T,E> dropTableEventVisitor, VisitorHandler<RenameColumnEvent,T,E> renameColumnEventVisitor, VisitorHandler<TruncateTableEvent,T,E> truncateTableEventVisitor, VisitorHandler<AlterTableCommentEvent,T,E> alterTableCommentEventVisitor)
static <E extends Throwable> void	SchemaChangeEventVisitor.voidVisit(SchemaChangeEvent event, VoidVisitorHandler<AddColumnEvent,E> addColumnVisitor, VoidVisitorHandler<AlterColumnTypeEvent,E> alterColumnTypeEventVisitor, VoidVisitorHandler<CreateTableEvent,E> createTableEventVisitor, VoidVisitorHandler<DropColumnEvent,E> dropColumnEventVisitor, VoidVisitorHandler<DropTableEvent,E> dropTableEventVisitor, VoidVisitorHandler<RenameColumnEvent,E> renameColumnEventVisitor, VoidVisitorHandler<TruncateTableEvent,E> truncateTableEventVisitor, VoidVisitorHandler<AlterTableCommentEvent,E> alterTableCommentEventHandler)

Uses of SchemaChangeEvent in org.apache.flink.cdc.common.exceptions

Fields in org.apache.flink.cdc.common.exceptions declared as SchemaChangeEvent

Modifier and Type	Field	Description
protected SchemaChangeEvent	SchemaEvolveException.applyingEvent

Methods in org.apache.flink.cdc.common.exceptions that return SchemaChangeEvent

Modifier and Type	Method	Description
SchemaChangeEvent	SchemaEvolveException.getApplyingEvent()

Constructors in org.apache.flink.cdc.common.exceptions with parameters of type SchemaChangeEvent

Constructor	Description
SchemaEvolveException(SchemaChangeEvent applyingEvent, String exceptionMessage)
SchemaEvolveException(SchemaChangeEvent applyingEvent, String exceptionMessage, Throwable cause)
UnsupportedSchemaChangeEventException(SchemaChangeEvent applyingEvent)
UnsupportedSchemaChangeEventException(SchemaChangeEvent applyingEvent, String exceptionMessage)
UnsupportedSchemaChangeEventException(SchemaChangeEvent applyingEvent, String exceptionMessage, Throwable cause)

Uses of SchemaChangeEvent in org.apache.flink.cdc.common.sink

Methods in org.apache.flink.cdc.common.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	MetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)	Apply the given SchemaChangeEvent to external systems.

Uses of SchemaChangeEvent in org.apache.flink.cdc.common.utils

Methods in org.apache.flink.cdc.common.utils that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
static List<SchemaChangeEvent>	SchemaMergingUtils.getSchemaDifference(TableId tableId, Schema beforeSchema, Schema afterSchema)	Generating what schema change events we need to do by converting compatible beforeSchema to afterSchema.
static Optional<SchemaChangeEvent>	SchemaUtils.transformSchemaChangeEvent(boolean hasAsterisk, List<String> referencedColumns, SchemaChangeEvent event)	This function determines if the given schema change event event should be sent to downstream based on if the given transform rule has asterisk, and what columns are referenced.

Methods in org.apache.flink.cdc.common.utils with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
static Schema	SchemaUtils.applySchemaChangeEvent(Schema schema, SchemaChangeEvent event)	apply SchemaChangeEvent to the old schema and return the schema after changing.
static boolean	SchemaUtils.isSchemaChangeEventRedundant(Schema currentSchema, SchemaChangeEvent event)	This function checks if the given schema change event has been applied already.
static Optional<SchemaChangeEvent>	SchemaUtils.transformSchemaChangeEvent(boolean hasAsterisk, List<String> referencedColumns, SchemaChangeEvent event)	This function determines if the given schema change event event should be sent to downstream based on if the given transform rule has asterisk, and what columns are referenced.

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.doris.sink

Methods in org.apache.flink.cdc.connectors.doris.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	DorisMetadataApplier.applySchemaChange(SchemaChangeEvent event)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.fluss.sink

Methods in org.apache.flink.cdc.connectors.fluss.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	FlussMetaDataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.hudi.sink

Methods in org.apache.flink.cdc.connectors.hudi.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	HudiMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.hudi.sink.function

Methods in org.apache.flink.cdc.connectors.hudi.sink.function with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	EventProcessorFunction.processSchemaChange(SchemaChangeEvent event)	Process schema change events (CREATE TABLE, ADD COLUMN, etc.).
void	MultiTableEventStreamWriteFunction.processSchemaChange(SchemaChangeEvent event)	Processes schema events.

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.iceberg.sink

Methods in org.apache.flink.cdc.connectors.iceberg.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	IcebergMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.kafka.sink

Methods in org.apache.flink.cdc.connectors.kafka.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	KafkaMetaDataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.maxcompute

Methods in org.apache.flink.cdc.connectors.maxcompute with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	MaxComputeMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.mysql.source

Methods in org.apache.flink.cdc.connectors.mysql.source that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
protected List<SchemaChangeEvent>	MySqlEventDeserializer.deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.mysql.source.parser

Methods in org.apache.flink.cdc.connectors.mysql.source.parser that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
List<SchemaChangeEvent>	CustomMySqlAntlrDdlParser.getAndClearParsedEvents()

Constructor parameters in org.apache.flink.cdc.connectors.mysql.source.parser with type arguments of type SchemaChangeEvent

Constructor	Description
CustomAlterTableParserListener(io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser parser, List<org.antlr.v4.runtime.tree.ParseTreeListener> listeners, LinkedList<SchemaChangeEvent> changes, boolean tinyInt1isBit, boolean isTableIdCaseInsensitive)
CustomMySqlAntlrDdlParserListener(io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser parser, LinkedList<SchemaChangeEvent> parsedEvents, boolean tinyInt1isBit, boolean isTableIdCaseInsensitive)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.oceanbase.sink

Methods in org.apache.flink.cdc.connectors.oceanbase.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	OceanBaseMetadataApplier.applySchemaChange(SchemaChangeEvent event)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.oracle.source

Methods in org.apache.flink.cdc.connectors.oracle.source that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
protected List<SchemaChangeEvent>	OracleEventDeserializer.deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.oracle.source.parser

Methods in org.apache.flink.cdc.connectors.oracle.source.parser that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
List<SchemaChangeEvent>	OracleAntlrDdlParser.getAndClearParsedEvents()

Constructor parameters in org.apache.flink.cdc.connectors.oracle.source.parser with type arguments of type SchemaChangeEvent

Constructor	Description
OracleAlterTableParserListener(String catalogName, String schemaName, io.debezium.connector.oracle.antlr.OracleDdlParser parser, List<org.antlr.v4.runtime.tree.ParseTreeListener> listeners, LinkedList<SchemaChangeEvent> changes)	Package visible Constructor.
OracleAntlrDdlParserListener(String catalogName, String schemaName, io.debezium.connector.oracle.antlr.OracleDdlParser parser, LinkedList<SchemaChangeEvent> parsedEvents)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.paimon.sink

Methods in org.apache.flink.cdc.connectors.paimon.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	PaimonMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket

Methods in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket that return SchemaChangeEvent

Modifier and Type	Method	Description
SchemaChangeEvent	BucketAssignOperator.convertSchemaChangeEvent(SchemaChangeEvent schemaChangeEvent)

Methods in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
SchemaChangeEvent	BucketAssignOperator.convertSchemaChangeEvent(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.postgres.source

Methods in org.apache.flink.cdc.connectors.postgres.source that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
protected List<SchemaChangeEvent>	PostgresEventDeserializer.deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.postgres.utils

Methods in org.apache.flink.cdc.connectors.postgres.utils that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
static List<SchemaChangeEvent>	SchemaChangeUtil.inferSchemaChangeEvent(io.debezium.relational.TableId dbzTableId, io.debezium.relational.Table tableBefore, io.debezium.relational.Table tableAfter, PostgresSourceConfig sourceConfig, io.debezium.connector.postgresql.TypeRegistry typeRegistry)	Infers the minimum list of schema change events that transform tableBefore into tableAfter.

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.sqlserver.source

Methods in org.apache.flink.cdc.connectors.sqlserver.source that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
protected List<SchemaChangeEvent>	SqlServerEventDeserializer.deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.starrocks.sink

Methods in org.apache.flink.cdc.connectors.starrocks.sink with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	StarRocksMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)

Uses of SchemaChangeEvent in org.apache.flink.cdc.connectors.values

Methods in org.apache.flink.cdc.connectors.values with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	ValuesDatabase.ErrorOnChangeMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)
void	ValuesDatabase.ValuesMetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent)
static void	ValuesDatabase.applySchemaChangeEvent(SchemaChangeEvent event)

Uses of SchemaChangeEvent in org.apache.flink.cdc.debezium.event

Methods in org.apache.flink.cdc.debezium.event that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
protected abstract List<SchemaChangeEvent>	SourceRecordEventDeserializer.deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)	Deserialize given schema change record to SchemaChangeEvent.

Uses of SchemaChangeEvent in org.apache.flink.cdc.runtime.operators.schema.common

Methods in org.apache.flink.cdc.runtime.operators.schema.common that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
static List<SchemaChangeEvent>	SchemaDerivator.normalizeSchemaChangeEvents(Schema oldSchema, List<SchemaChangeEvent> schemaChangeEvents, SchemaChangeBehavior schemaChangeBehavior, MetadataApplier metadataApplier)	Rewrite SchemaChangeEvents by current SchemaChangeBehavior and include / exclude them by fine-grained schema change event configurations.

Methods in org.apache.flink.cdc.runtime.operators.schema.common with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
void	SchemaManager.applyEvolvedSchemaChange(SchemaChangeEvent schemaChangeEvent)	Apply schema change to a table.
void	SchemaManager.applyOriginalSchemaChange(SchemaChangeEvent schemaChangeEvent)	Apply schema change to a table.
protected boolean	SchemaRegistry.expandExistingTableSchemaIfNeeded(SchemaChangeEvent schemaChangeEvent)	Handles the initial CreateTableEvent for an existing target table.

Method parameters in org.apache.flink.cdc.runtime.operators.schema.common with type arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
static List<SchemaChangeEvent>	SchemaDerivator.normalizeSchemaChangeEvents(Schema oldSchema, List<SchemaChangeEvent> schemaChangeEvents, SchemaChangeBehavior schemaChangeBehavior, MetadataApplier metadataApplier)	Rewrite SchemaChangeEvents by current SchemaChangeBehavior and include / exclude them by fine-grained schema change event configurations.

Uses of SchemaChangeEvent in org.apache.flink.cdc.runtime.operators.schema.distributed.event

Methods in org.apache.flink.cdc.runtime.operators.schema.distributed.event that return SchemaChangeEvent

Modifier and Type	Method	Description
SchemaChangeEvent	SchemaChangeRequest.getSchemaChangeEvent()

Methods in org.apache.flink.cdc.runtime.operators.schema.distributed.event that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
List<SchemaChangeEvent>	SchemaChangeResponse.getEvolvedSchemaChangeEvents()

Constructors in org.apache.flink.cdc.runtime.operators.schema.distributed.event with parameters of type SchemaChangeEvent

Constructor	Description
SchemaChangeRequest(int sourceSubTaskId, int sinkSubTaskId, SchemaChangeEvent schemaChangeEvent)

Constructor parameters in org.apache.flink.cdc.runtime.operators.schema.distributed.event with type arguments of type SchemaChangeEvent

Constructor	Description
SchemaChangeResponse(Map<TableId,Schema> evolvedSchemas, List<SchemaChangeEvent> evolvedSchemaChangeEvents)

Uses of SchemaChangeEvent in org.apache.flink.cdc.runtime.operators.schema.regular.event

Methods in org.apache.flink.cdc.runtime.operators.schema.regular.event that return SchemaChangeEvent

Modifier and Type	Method	Description
SchemaChangeEvent	SchemaChangeRequest.getSchemaChangeEvent()

Methods in org.apache.flink.cdc.runtime.operators.schema.regular.event that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
List<SchemaChangeEvent>	SchemaChangeResponse.getAppliedSchemaChangeEvents()

Constructors in org.apache.flink.cdc.runtime.operators.schema.regular.event with parameters of type SchemaChangeEvent

Constructor	Description
SchemaChangeRequest(TableId tableId, SchemaChangeEvent schemaChangeEvent, int subTaskId)

Constructor parameters in org.apache.flink.cdc.runtime.operators.schema.regular.event with type arguments of type SchemaChangeEvent

Constructor	Description
SchemaChangeResponse(List<SchemaChangeEvent> appliedSchemaChangeEvents, Map<TableId,Schema> evolvedSchemas)

Uses of SchemaChangeEvent in org.apache.flink.cdc.runtime.serializer.event

Methods in org.apache.flink.cdc.runtime.serializer.event that return SchemaChangeEvent

Modifier and Type	Method	Description
SchemaChangeEvent	SchemaChangeEventSerializer.copy(SchemaChangeEvent from)
SchemaChangeEvent	SchemaChangeEventSerializer.copy(SchemaChangeEvent from, SchemaChangeEvent reuse)
SchemaChangeEvent	SchemaChangeEventSerializer.createInstance()
SchemaChangeEvent	SchemaChangeEventSerializer.deserialize(SchemaChangeEvent reuse, org.apache.flink.core.memory.DataInputView source)
SchemaChangeEvent	SchemaChangeEventSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)

Methods in org.apache.flink.cdc.runtime.serializer.event that return types with arguments of type SchemaChangeEvent

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<SchemaChangeEvent>	SchemaChangeEventSerializer.snapshotConfiguration()

Methods in org.apache.flink.cdc.runtime.serializer.event with parameters of type SchemaChangeEvent

Modifier and Type	Method	Description
SchemaChangeEvent	SchemaChangeEventSerializer.copy(SchemaChangeEvent from)
SchemaChangeEvent	SchemaChangeEventSerializer.copy(SchemaChangeEvent from, SchemaChangeEvent reuse)
SchemaChangeEvent	SchemaChangeEventSerializer.deserialize(SchemaChangeEvent reuse, org.apache.flink.core.memory.DataInputView source)
void	SchemaChangeEventSerializer.serialize(SchemaChangeEvent record, org.apache.flink.core.memory.DataOutputView target)