Uses of Class
org.apache.flink.cdc.common.event.DataChangeEvent

Packages that use DataChangeEvent

Package	Description
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.utils
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.hudi.sink.function
org.apache.flink.cdc.connectors.hudi.sink.util
org.apache.flink.cdc.connectors.iceberg.sink.utils
org.apache.flink.cdc.connectors.maxcompute
org.apache.flink.cdc.connectors.maxcompute.sink
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.paimon.sink.v2
org.apache.flink.cdc.connectors.paimon.sink.v2.bucket
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.transform.converter
org.apache.flink.cdc.runtime.partitioning
org.apache.flink.cdc.runtime.serializer.event

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

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

Modifier and Type	Method	Description
static DataChangeEvent	DataChangeEvent.deleteEvent(TableId tableId, RecordData before)	Creates a DataChangeEvent instance that describes the delete event.
static DataChangeEvent	DataChangeEvent.deleteEvent(TableId tableId, RecordData before, Map<String,String> meta)	Creates a DataChangeEvent instance that describes the delete event with meta info.
static DataChangeEvent	DataChangeEvent.insertEvent(TableId tableId, RecordData after)	Creates a DataChangeEvent instance that describes the insert event.
static DataChangeEvent	DataChangeEvent.insertEvent(TableId tableId, RecordData after, Map<String,String> meta)	Creates a DataChangeEvent instance that describes the insert event with meta info.
static DataChangeEvent	DataChangeEvent.projectAfter(DataChangeEvent dataChangeEvent, RecordData projectedAfter)	Updates the after of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.projectBefore(DataChangeEvent dataChangeEvent, RecordData projectedBefore)	Updates the before of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.projectRecords(DataChangeEvent dataChangeEvent, RecordData projectedBefore, RecordData projectedAfter)	Updates the after of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.replaceEvent(TableId tableId, RecordData after)	Creates a DataChangeEvent instance that describes the replace event.
static DataChangeEvent	DataChangeEvent.replaceEvent(TableId tableId, RecordData after, Map<String,String> meta)	Creates a DataChangeEvent instance that describes the replace event with meta info.
static DataChangeEvent	DataChangeEvent.route(DataChangeEvent dataChangeEvent, TableId tableId)	Updates the TableId info of current data change event.
static DataChangeEvent	DataChangeEvent.updateEvent(TableId tableId, RecordData before, RecordData after)	Creates a DataChangeEvent instance that describes the update event.
static DataChangeEvent	DataChangeEvent.updateEvent(TableId tableId, RecordData before, RecordData after, Map<String,String> meta)	Creates a DataChangeEvent instance that describes the update event with meta info.

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

Modifier and Type	Method	Description
static DataChangeEvent	DataChangeEvent.projectAfter(DataChangeEvent dataChangeEvent, RecordData projectedAfter)	Updates the after of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.projectBefore(DataChangeEvent dataChangeEvent, RecordData projectedBefore)	Updates the before of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.projectRecords(DataChangeEvent dataChangeEvent, RecordData projectedBefore, RecordData projectedAfter)	Updates the after of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.route(DataChangeEvent dataChangeEvent, TableId tableId)	Updates the TableId info of current data change event.

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

Methods in org.apache.flink.cdc.common.sink that return types with arguments of type DataChangeEvent

Modifier and Type	Method	Description
default HashFunctionProvider<DataChangeEvent>	DataSink.getDataChangeEventHashFunctionProvider()	Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.
default HashFunctionProvider<DataChangeEvent>	DataSink.getDataChangeEventHashFunctionProvider(int parallelism)
HashFunction<DataChangeEvent>	DefaultDataChangeEventHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
HashFunction<DataChangeEvent>	ForwardHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
HashFunction<DataChangeEvent>	TableIdHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

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

Methods in org.apache.flink.cdc.common.utils that return DataChangeEvent

Modifier and Type	Method	Description
static DataChangeEvent	ChangeEventUtils.recreateDataChangeEvent(DataChangeEvent dataChangeEvent, TableId tableId)

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

Modifier and Type	Method	Description
static DataChangeEvent	ChangeEventUtils.recreateDataChangeEvent(DataChangeEvent dataChangeEvent, TableId tableId)

Uses of DataChangeEvent in org.apache.flink.cdc.composer.flink.translator

Method parameters in org.apache.flink.cdc.composer.flink.translator with type arguments of type DataChangeEvent

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<PartitioningEvent>	PartitioningTranslator.translateDistributed(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int upstreamParallelism, int downstreamParallelism, HashFunctionProvider<DataChangeEvent> hashFunctionProvider)
org.apache.flink.streaming.api.datastream.DataStream<Event>	PartitioningTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int upstreamParallelism, int downstreamParallelism, boolean isBatchMode, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, HashFunctionProvider<DataChangeEvent> hashFunctionProvider, OperatorUidGenerator operatorUidGenerator)
org.apache.flink.streaming.api.datastream.DataStream<Event>	PartitioningTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int upstreamParallelism, int downstreamParallelism, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, HashFunctionProvider<DataChangeEvent> hashFunctionProvider, OperatorUidGenerator operatorUidGenerator)

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

Methods in org.apache.flink.cdc.connectors.fluss.sink that return types with arguments of type DataChangeEvent

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	FlussDataSink.getDataChangeEventHashFunctionProvider()
HashFunction<DataChangeEvent>	FlussHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

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

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

Modifier and Type	Method	Description
void	EventProcessorFunction.processDataChange(DataChangeEvent event, org.apache.flink.streaming.api.functions.ProcessFunction.Context ctx, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)	Process data change events (INSERT, UPDATE, DELETE operations).
void	MultiTableEventStreamWriteFunction.processDataChange(DataChangeEvent event, org.apache.flink.streaming.api.functions.ProcessFunction.Context ctx, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)	Processes change events with context and collector for writing.

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

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

Modifier and Type	Method	Description
static org.apache.hudi.client.model.HoodieFlinkInternalRow	RowDataUtils.convertDataChangeEventToHoodieFlinkInternalRow(DataChangeEvent dataChangeEvent, Schema schema, java.time.ZoneId zoneId, org.apache.hudi.sink.bulk.RowDataKeyGen keyGen, String fileId, String instantTime)	Convert a DataChangeEvent to a HoodieFlinkInternalRow with automatic record key and partition path extraction using Hudi's RowDataKeyGen.
static String	RowDataUtils.extractPartitionPathFromDataChangeEvent(DataChangeEvent dataChangeEvent, Schema schema)	Extract partition path from DataChangeEvent based on partition key fields in schema.
static String	RowDataUtils.extractRecordKeyFromDataChangeEvent(DataChangeEvent dataChangeEvent, Schema schema)	Extract record key from DataChangeEvent based on primary key fields in schema.

Uses of DataChangeEvent in org.apache.flink.cdc.connectors.iceberg.sink.utils

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

Modifier and Type	Method	Description
static List<org.apache.flink.table.data.RowData>	RowDataUtils.convertDataChangeEventToRowData(DataChangeEvent dataChangeEvent, List<RecordData.FieldGetter> fieldGetters)	Convert a DataChangeEvent to one or two RowData.

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

Methods in org.apache.flink.cdc.connectors.maxcompute that return types with arguments of type DataChangeEvent

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	MaxComputeDataSink.getDataChangeEventHashFunctionProvider()

Uses of DataChangeEvent in org.apache.flink.cdc.connectors.maxcompute.sink

Methods in org.apache.flink.cdc.connectors.maxcompute.sink that return types with arguments of type DataChangeEvent

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	MaxComputeHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

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

Methods in org.apache.flink.cdc.connectors.paimon.sink that return types with arguments of type DataChangeEvent

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	PaimonDataSink.getDataChangeEventHashFunctionProvider(int parallelism)
HashFunction<DataChangeEvent>	PaimonHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

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

Modifier and Type	Method	Description
int	PaimonHashFunction.hashcode(DataChangeEvent event)

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

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

Modifier and Type	Method	Description
static List<org.apache.paimon.data.GenericRow>	PaimonWriterHelper.convertEventToFullGenericRows(DataChangeEvent dataChangeEvent, List<RecordData.FieldGetter> fieldGetters, boolean hasPrimaryKey)	create full GenericRows from a DataChangeEvent for PaimonWriter.
static org.apache.paimon.data.GenericRow	PaimonWriterHelper.convertEventToGenericRow(DataChangeEvent dataChangeEvent, List<RecordData.FieldGetter> fieldGetters)	create a GenericRow from a DataChangeEvent for PaimonWriter.

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

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

Modifier and Type	Method	Description
DataChangeEvent	BucketAssignOperator.convertDataChangeEvent(DataChangeEvent dataChangeEvent)

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

Modifier and Type	Method	Description
DataChangeEvent	BucketAssignOperator.convertDataChangeEvent(DataChangeEvent dataChangeEvent)

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

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

Modifier and Type	Method	Description
static void	ValuesDatabase.applyDataChangeEvent(DataChangeEvent event)

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

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

Modifier and Type	Method	Description
List<DataChangeEvent>	DebeziumEventDeserializationSchema.deserializeDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)
protected abstract List<DataChangeEvent>	SourceRecordEventDeserializer.deserializeDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)	Deserialize given data change record to DataChangeEvent.

Uses of DataChangeEvent 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 DataChangeEvent

Modifier and Type	Method	Description
Optional<DataChangeEvent>	SchemaDerivator.coerceDataRecord(String timezone, DataChangeEvent dataChangeEvent, Schema upstreamSchema, Schema evolvedSchema)	Coerce a DataChangeEvent from upstream to expected downstream schema.

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

Modifier and Type	Method	Description
Optional<DataChangeEvent>	SchemaDerivator.coerceDataRecord(String timezone, DataChangeEvent dataChangeEvent, Schema upstreamSchema, Schema evolvedSchema)	Coerce a DataChangeEvent from upstream to expected downstream schema.

Uses of DataChangeEvent in org.apache.flink.cdc.runtime.operators.transform.converter

Methods in org.apache.flink.cdc.runtime.operators.transform.converter that return types with arguments of type DataChangeEvent

Modifier and Type	Method	Description
Optional<DataChangeEvent>	PostTransformConverter.convert(DataChangeEvent dataChangeEvent)	Change some parts of DataChangeEvent, like op or meta.
Optional<DataChangeEvent>	SoftDeleteConverter.convert(DataChangeEvent dataChangeEvent)

Methods in org.apache.flink.cdc.runtime.operators.transform.converter with parameters of type DataChangeEvent

Modifier and Type	Method	Description
Optional<DataChangeEvent>	PostTransformConverter.convert(DataChangeEvent dataChangeEvent)	Change some parts of DataChangeEvent, like op or meta.
Optional<DataChangeEvent>	SoftDeleteConverter.convert(DataChangeEvent dataChangeEvent)

Uses of DataChangeEvent in org.apache.flink.cdc.runtime.partitioning

Constructor parameters in org.apache.flink.cdc.runtime.partitioning with type arguments of type DataChangeEvent

Constructor	Description
BatchRegularPrePartitionOperator(int downstreamParallelism, HashFunctionProvider<DataChangeEvent> hashFunctionProvider)
DistributedPrePartitionOperator(int downstreamParallelism, HashFunctionProvider<DataChangeEvent> hashFunctionProvider)
RegularPrePartitionOperator(org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorId, int downstreamParallelism, HashFunctionProvider<DataChangeEvent> hashFunctionProvider)

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

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

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

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

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

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

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