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

Packages that use ChangeEvent

Package	Description
org.apache.flink.cdc.common.event
org.apache.flink.cdc.connectors.hudi.sink.util
org.apache.flink.cdc.connectors.paimon.sink.v2.bucket
org.apache.flink.cdc.debezium.event

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

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

Modifier and Type	Interface	Description
interface	SchemaChangeEvent	Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
interface	SchemaChangeEventWithPreSchema	A SchemaChangeEvent that supports appending schema before change event.

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

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	DataChangeEvent	Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
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.

Uses of ChangeEvent in org.apache.flink.cdc.connectors.hudi.sink.util

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

Modifier and Type	Method	Description
static org.apache.flink.table.data.RowData	RowDataUtils.convertDataChangeEventToRowData(ChangeEvent changeEvent, List<RecordData.FieldGetter> fieldGetters)	Convert DataChangeEvent to RowData.

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

Classes in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket that implement ChangeEvent

Modifier and Type	Class	Description
class	BucketWrapperChangeEvent	A wrapper class for ChangeEvent to attach bucket id.

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

Modifier and Type	Method	Description
ChangeEvent	BucketWrapperChangeEvent.getInnerEvent()

Constructors in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket with parameters of type ChangeEvent

Constructor	Description
BucketWrapperChangeEvent(int bucket, int partition, ChangeEvent innerEvent)

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

Methods in org.apache.flink.cdc.debezium.event with parameters of type ChangeEvent

Modifier and Type	Method	Description
void	DebeziumEventDeserializationSchema.applyChangeEvent(ChangeEvent changeEvent)