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

Packages that use Event

Package	Description
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.source
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.doris.sink
org.apache.flink.cdc.connectors.elasticsearch.serializer
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.fluss.source.deserializer
org.apache.flink.cdc.connectors.hudi.sink.bucket
org.apache.flink.cdc.connectors.hudi.sink.event
org.apache.flink.cdc.connectors.hudi.sink.function
org.apache.flink.cdc.connectors.hudi.sink.operator
org.apache.flink.cdc.connectors.hudi.sink.v2
org.apache.flink.cdc.connectors.iceberg.sink.v2
org.apache.flink.cdc.connectors.kafka.json
org.apache.flink.cdc.connectors.kafka.json.canal
org.apache.flink.cdc.connectors.kafka.json.debezium
org.apache.flink.cdc.connectors.kafka.serialization
org.apache.flink.cdc.connectors.kafka.sink
org.apache.flink.cdc.connectors.maxcompute.coordinator
org.apache.flink.cdc.connectors.maxcompute.sink
org.apache.flink.cdc.connectors.mysql.source.reader
org.apache.flink.cdc.connectors.oceanbase.sink
org.apache.flink.cdc.connectors.oracle.source.reader
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.sqlserver.source
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.connectors.values.sink
org.apache.flink.cdc.connectors.values.source
org.apache.flink.cdc.debezium.event
org.apache.flink.cdc.runtime.operators.schema.distributed
org.apache.flink.cdc.runtime.operators.schema.regular
org.apache.flink.cdc.runtime.operators.sink
org.apache.flink.cdc.runtime.operators.sink.exception
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.operators.transform.async
org.apache.flink.cdc.runtime.operators.transform.exceptions
org.apache.flink.cdc.runtime.partitioning
org.apache.flink.cdc.runtime.serializer.event
org.apache.flink.cdc.runtime.typeutils

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

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

Modifier and Type	Interface	Description
interface	ChangeEvent	Class ChangeEvent represents the change events of external systems, including DataChangeEvent and SchemaChangeEvent.
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 Event

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	FlushEvent	An Event from SchemaOperator to notify DataSinkWriterOperator that it start flushing.
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 types with arguments of type Event

Modifier and Type	Method	Description
List<? extends Event>	EventDeserializer.deserialize(T record)	Deserialize given record to Events.

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

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

Modifier and Type	Method	Description
org.apache.flink.api.connector.sink2.Sink<Event>	FlinkSinkProvider.getSink()	Get the Sink for writing events to external systems.
org.apache.flink.streaming.api.functions.sink.SinkFunction<Event>	FlinkSinkFunctionProvider.getSinkFunction()	Get the SinkFunction for writing events to external systems.

Method parameters in org.apache.flink.cdc.common.sink with type arguments of type Event

Modifier and Type	Method	Description
static FlinkSinkFunctionProvider	FlinkSinkFunctionProvider.of(org.apache.flink.streaming.api.functions.sink.SinkFunction<Event> sinkFunction)	Create a FlinkSinkFunctionProvider from a SinkFunction.
static FlinkSinkProvider	FlinkSinkProvider.of(org.apache.flink.api.connector.sink2.Sink<Event> sink)	Create a FlinkSinkProvider from a Sink.

Uses of Event in org.apache.flink.cdc.common.source

Methods in org.apache.flink.cdc.common.source that return types with arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.Source<Event,?,?>	FlinkSourceProvider.getSource()	Get the Source for reading events from external systems.
org.apache.flink.streaming.api.functions.source.SourceFunction<Event>	FlinkSourceFunctionProvider.getSourceFunction()	Get the SourceFunction for reading events from external systems.

Method parameters in org.apache.flink.cdc.common.source with type arguments of type Event

Modifier and Type	Method	Description
static FlinkSourceFunctionProvider	FlinkSourceFunctionProvider.of(org.apache.flink.streaming.api.functions.source.SourceFunction<Event> sourceFunction)	Create a FlinkSourceFunctionProvider from a SourceFunction.
static FlinkSourceProvider	FlinkSourceProvider.of(org.apache.flink.api.connector.source.Source<Event,?,?> source)	Create a FlinkSourceProvider from a Source.

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

Methods in org.apache.flink.cdc.composer.flink.translator that return types with arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	DataSourceTranslator.translate(SourceDef sourceDef, DataSource dataSource, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, int sourceParallelism, OperatorUidGenerator operatorUidGenerator)
org.apache.flink.streaming.api.datastream.DataStream<Event>	TransformTranslator.translateAsyncPostTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns, OperatorUidGenerator operatorUidGenerator, java.time.Duration asyncTransformTimeout, int asyncTransformCapacity, int asyncTransformWorkerThreads, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateDistributed(org.apache.flink.streaming.api.datastream.DataStream<PartitioningEvent> input, int parallelism, MetadataApplier metadataApplier, List<RouteDef> routes, RouteMode routeMode)
org.apache.flink.streaming.api.datastream.DataStream<Event>	TransformTranslator.translatePostTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns, OperatorUidGenerator operatorUidGenerator, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
org.apache.flink.streaming.api.datastream.DataStream<Event>	TransformTranslator.translatePreTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns)
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)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, boolean isBatchMode, MetadataApplier metadataApplier, List<RouteDef> routes)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, boolean isBatchMode, MetadataApplier metadataApplier, List<RouteDef> routes, RouteMode routeMode)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, MetadataApplier metadataApplier, List<RouteDef> routes)

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

Modifier and Type	Method	Description
void	DataSinkTranslator.translate(SinkDef sinkDef, org.apache.flink.streaming.api.datastream.DataStream<Event> input, DataSink dataSink, boolean isBatchMode, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, OperatorUidGenerator operatorUidGenerator)
void	DataSinkTranslator.translate(SinkDef sinkDef, org.apache.flink.streaming.api.datastream.DataStream<Event> input, DataSink dataSink, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, OperatorUidGenerator operatorUidGenerator)
org.apache.flink.streaming.api.datastream.DataStream<Event>	TransformTranslator.translateAsyncPostTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns, OperatorUidGenerator operatorUidGenerator, java.time.Duration asyncTransformTimeout, int asyncTransformCapacity, int asyncTransformWorkerThreads, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
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>	TransformTranslator.translatePostTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns, OperatorUidGenerator operatorUidGenerator, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
org.apache.flink.streaming.api.datastream.DataStream<Event>	TransformTranslator.translatePreTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns)
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)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, boolean isBatchMode, MetadataApplier metadataApplier, List<RouteDef> routes)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, boolean isBatchMode, MetadataApplier metadataApplier, List<RouteDef> routes, RouteMode routeMode)
org.apache.flink.streaming.api.datastream.DataStream<Event>	SchemaOperatorTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int parallelism, MetadataApplier metadataApplier, List<RouteDef> routes)

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

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

Modifier and Type	Method	Description
org.apache.doris.flink.sink.writer.serializer.DorisRecord	DorisEventSerializer.serialize(Event event)

Uses of Event in org.apache.flink.cdc.connectors.elasticsearch.serializer

Methods in org.apache.flink.cdc.connectors.elasticsearch.serializer with parameters of type Event

Modifier and Type	Method	Description
co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant	ElasticsearchEventSerializer.apply(Event event, org.apache.flink.api.connector.sink2.SinkWriter.Context context)

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

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

Modifier and Type	Method	Description
FlussEvent	FlussEventSerializationSchema.serialize(Event event)

Uses of Event in org.apache.flink.cdc.connectors.fluss.source.deserializer

Methods in org.apache.flink.cdc.connectors.fluss.source.deserializer that return types with arguments of type Event

Modifier and Type	Method	Description
List<Event>	FlussRecordDeserializer.deserialize(FlussSourceRecord record, org.apache.fluss.metadata.TablePath tablePath)
List<Event>	FlussRecordDeserializer.restoreState(org.apache.fluss.metadata.TablePath tablePath, int schemaId, org.apache.fluss.types.RowType rowType)	Restores the internal schema caches from a recovered split.

Uses of Event in org.apache.flink.cdc.connectors.hudi.sink.bucket

Classes in org.apache.flink.cdc.connectors.hudi.sink.bucket that implement Event

Modifier and Type	Class	Description
class	BucketWrapper	Wrapper class that implements Event and associates an event with a target bucket/task index.
class	BucketWrapperFlushEvent	A wrapper class for FlushEvent to attach bucket id and task metadata.

Methods in org.apache.flink.cdc.connectors.hudi.sink.bucket that return Event

Modifier and Type	Method	Description
Event	BucketWrapper.getEvent()

Method parameters in org.apache.flink.cdc.connectors.hudi.sink.bucket with type arguments of type Event

Modifier and Type	Method	Description
void	BucketAssignOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> streamRecord)

Constructors in org.apache.flink.cdc.connectors.hudi.sink.bucket with parameters of type Event

Constructor	Description
BucketWrapper(int bucket, Event event)

Uses of Event in org.apache.flink.cdc.connectors.hudi.sink.event

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

Modifier and Type	Method	Description
org.apache.hudi.client.model.HoodieFlinkInternalRow	HudiRecordEventSerializer.serialize(Event event)	Serialize an Event into HoodieFlinkInternalRow without fileId and instantTime.
org.apache.hudi.client.model.HoodieFlinkInternalRow	HudiRecordEventSerializer.serialize(Event event, String fileId, String instantTime)	Serialize an Event into HoodieFlinkInternalRow.

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

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

Modifier and Type	Method	Description
void	MultiTableEventStreamWriteFunction.processElement(Event event, org.apache.flink.streaming.api.functions.ProcessFunction.Context ctx, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)

Uses of Event in org.apache.flink.cdc.connectors.hudi.sink.operator

Methods in org.apache.flink.cdc.connectors.hudi.sink.operator that return types with arguments of type Event

Modifier and Type	Method	Description
static MultiTableWriteOperatorFactory<Event>	MultiTableWriteOperator.getFactory(org.apache.flink.configuration.Configuration conf, String schemaOperatorUid)	Creates a MultiTableWriteOperatorFactory for multi-table Hudi write operations.

Uses of Event in org.apache.flink.cdc.connectors.hudi.sink.v2

Methods in org.apache.flink.cdc.connectors.hudi.sink.v2 that return types with arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	HudiSink.addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> dataStream)
org.apache.flink.api.connector.sink2.SinkWriter<Event>	HudiSink.createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext context)
org.apache.flink.api.connector.sink2.SinkWriter<Event>	HudiSink.createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)

Method parameters in org.apache.flink.cdc.connectors.hudi.sink.v2 with type arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	HudiSink.addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> dataStream)

Uses of Event in org.apache.flink.cdc.connectors.iceberg.sink.v2

Methods in org.apache.flink.cdc.connectors.iceberg.sink.v2 that return types with arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	IcebergSink.addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> dataStream)
org.apache.flink.api.connector.sink2.SinkWriter<Event>	IcebergSink.createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext context)	Deprecated.
org.apache.flink.api.connector.sink2.SinkWriter<Event>	IcebergSink.createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)
org.apache.flink.api.connector.sink2.StatefulSinkWriter<Event,IcebergWriterState>	IcebergSink.restoreWriter(org.apache.flink.api.connector.sink2.WriterInitContext context, Collection<IcebergWriterState> writerStates)

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

Modifier and Type	Method	Description
void	IcebergWriter.write(Event event, org.apache.flink.api.connector.sink2.SinkWriter.Context context)

Method parameters in org.apache.flink.cdc.connectors.iceberg.sink.v2 with type arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	IcebergSink.addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> dataStream)

Uses of Event in org.apache.flink.cdc.connectors.kafka.json

Methods in org.apache.flink.cdc.connectors.kafka.json that return types with arguments of type Event

Modifier and Type	Method	Description
static org.apache.flink.api.common.serialization.SerializationSchema<Event>	ChangeLogJsonFormatFactory.createSerializationSchema(org.apache.flink.configuration.ReadableConfig formatOptions, JsonSerializationType type, java.time.ZoneId zoneId)	Creates a configured instance of SerializationSchema to convert Event to json.

Uses of Event in org.apache.flink.cdc.connectors.kafka.json.canal

Methods in org.apache.flink.cdc.connectors.kafka.json.canal with parameters of type Event

Modifier and Type	Method	Description
byte[]	CanalJsonSerializationSchema.serialize(Event event)

Uses of Event in org.apache.flink.cdc.connectors.kafka.json.debezium

Methods in org.apache.flink.cdc.connectors.kafka.json.debezium with parameters of type Event

Modifier and Type	Method	Description
byte[]	DebeziumJsonSerializationSchema.serialize(Event event)

Uses of Event in org.apache.flink.cdc.connectors.kafka.serialization

Methods in org.apache.flink.cdc.connectors.kafka.serialization with parameters of type Event

Modifier and Type	Method	Description
byte[]	CsvSerializationSchema.serialize(Event event)
byte[]	JsonSerializationSchema.serialize(Event event)

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

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

Modifier and Type	Method	Description
static org.apache.flink.api.common.serialization.SerializationSchema<Event>	KeySerializationFactory.createSerializationSchema(org.apache.flink.configuration.ReadableConfig formatOptions, KeyFormat keyFormat, java.time.ZoneId zoneId)	Creates a configured instance of SerializationSchema to convert Event to byte.

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

Modifier and Type	Method	Description
org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>	PipelineKafkaRecordSerializationSchema.serialize(Event event, org.apache.flink.connector.kafka.sink.KafkaRecordSerializationSchema.KafkaSinkContext context, Long timestamp)

Constructor parameters in org.apache.flink.cdc.connectors.kafka.sink with type arguments of type Event

Constructor

Description

KafkaDataSink(org.apache.flink.connector.base.DeliveryGuarantee deliveryGuarantee, Properties kafkaProperties, PartitionStrategy partitionStrategy, java.time.ZoneId zoneId, org.apache.flink.api.common.serialization.SerializationSchema<Event> keySerialization, org.apache.flink.api.common.serialization.SerializationSchema<Event> valueSerialization, String topic, boolean addTableToHeaderEnabled, String customHeaders, String tableMapping)

Uses of Event in org.apache.flink.cdc.connectors.maxcompute.coordinator

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

Modifier and Type	Method	Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<Event>> T	SessionManageCoordinatedOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Event> parameters)

Method parameters in org.apache.flink.cdc.connectors.maxcompute.coordinator with type arguments of type Event

Modifier and Type	Method	Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<Event>> T	SessionManageCoordinatedOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Event> parameters)
void	SessionManageOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)
void	SessionManageOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event>> output)

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

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

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	MaxComputeEventSink.addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> inputDataStream)
org.apache.flink.api.connector.sink2.SinkWriter<Event>	MaxComputeEventSink.createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext context)
org.apache.flink.api.connector.sink2.SinkWriter<Event>	MaxComputeEventSink.createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)

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

Modifier and Type	Method	Description
void	MaxComputeEventWriter.write(Event element, org.apache.flink.api.connector.sink2.SinkWriter.Context context)

Method parameters in org.apache.flink.cdc.connectors.maxcompute.sink with type arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	MaxComputeEventSink.addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> inputDataStream)

Uses of Event in org.apache.flink.cdc.connectors.mysql.source.reader

Method parameters in org.apache.flink.cdc.connectors.mysql.source.reader with type arguments of type Event

Modifier and Type	Method	Description
protected void	MySqlPipelineRecordEmitter.processElement(org.apache.kafka.connect.source.SourceRecord element, org.apache.flink.api.connector.source.SourceOutput<Event> output, MySqlSplitState splitState)

Constructor parameters in org.apache.flink.cdc.connectors.mysql.source.reader with type arguments of type Event

Constructor	Description
MySqlPipelineRecordEmitter(DebeziumDeserializationSchema<Event> debeziumDeserializationSchema, MySqlSourceReaderMetrics sourceReaderMetrics, MySqlSourceConfig sourceConfig, boolean isTableIdCaseInsensitive)

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

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

Modifier and Type	Method	Description
com.oceanbase.connector.flink.table.Record	OceanBaseEventSerializationSchema.serialize(Event event)

Uses of Event in org.apache.flink.cdc.connectors.oracle.source.reader

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

Modifier and Type	Method	Description
IncrementalSourceReader<Event,JdbcSourceConfig>	OracleTableSourceReader.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,Event,SourceSplitState>	OracleTableSourceReader.createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)

Method parameters in org.apache.flink.cdc.connectors.oracle.source.reader with type arguments of type Event

Modifier and Type	Method	Description
protected void	OraclePipelineRecordEmitter.processElement(org.apache.kafka.connect.source.SourceRecord element, org.apache.flink.api.connector.source.SourceOutput<Event> output, SourceSplitState splitState)

Constructor parameters in org.apache.flink.cdc.connectors.oracle.source.reader with type arguments of type Event

Constructor	Description
OraclePipelineRecordEmitter(DebeziumDeserializationSchema<Event> debeziumDeserializationSchema, SourceReaderMetrics sourceReaderMetrics, boolean includeSchemaChanges, OffsetFactory offsetFactory, OracleSourceConfig sourceConfig)
OracleTableSourceReader(OracleSourceConfigFactory configFactory, DebeziumDeserializationSchema<Event> deserializationSchema, RedoLogOffsetFactory offsetFactory, OracleDialect dataSourceDialect)

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

Constructor parameters in org.apache.flink.cdc.connectors.paimon.sink with type arguments of type Event

Constructor	Description
PaimonDataSink(org.apache.paimon.options.Options options, Map<String,String> tableOptions, String commitUser, Map<TableId,List<String>> partitionMaps, PaimonRecordSerializer<Event> serializer, java.time.ZoneId zoneId, String schemaOperatorUid)

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

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

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	PaimonEventSink.addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> dataStream)

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

Modifier and Type	Method	Description
PaimonEvent	PaimonRecordEventSerializer.serialize(Event event)

Method parameters in org.apache.flink.cdc.connectors.paimon.sink.v2 with type arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	PaimonEventSink.addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> dataStream)

Constructor parameters in org.apache.flink.cdc.connectors.paimon.sink.v2 with type arguments of type Event

Constructor	Description
PaimonEventSink(org.apache.paimon.options.Options catalogOptions, String commitUser, PaimonRecordSerializer<Event> serializer, String schemaOperatorUid, java.time.ZoneId zoneId)

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

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

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

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

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

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

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializer<Event>	BucketWrapperEventTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig config)
org.apache.flink.api.common.typeutils.TypeSerializer<Event>	BucketWrapperEventTypeInfo.createSerializer(org.apache.flink.api.common.serialization.SerializerConfig config)
Class<Event>	BucketWrapperEventTypeInfo.getTypeClass()
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Event>	BucketWrapperEventSerializer.snapshotConfiguration()

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

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

Method parameters in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket with type arguments of type Event

Modifier and Type	Method	Description
void	BucketAssignOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> streamRecord)
void	FlushEventAlignmentOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> streamRecord)
void	BucketAssignOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event>> output)

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

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

Modifier and Type	Method	Description
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,Event,SourceSplitState>	SqlServerPipelineSource.createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)

Constructor parameters in org.apache.flink.cdc.connectors.sqlserver.source with type arguments of type Event

Constructor	Description
SqlServerPipelineSource(SqlServerSourceConfigFactory configFactory, DebeziumDeserializationSchema<Event> deserializationSchema, LsnFactory offsetFactory, SqlServerDialect dataSourceDialect)

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

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

Modifier and Type	Method	Description
com.starrocks.connector.flink.table.data.StarRocksRowData	EventRecordSerializationSchema.serialize(Event record)

Uses of Event in org.apache.flink.cdc.connectors.values.sink

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

Modifier and Type	Method	Description
static String	ValuesDataSinkHelper.convertEventToStr(Event event, List<DataType> dataTypes, List<RecordData.FieldGetter> fieldGetters)	convert Event to String for ValuesDataSink to display detail message.
void	ValuesDataSinkFunction.invoke(Event event, org.apache.flink.streaming.api.functions.sink.SinkFunction.Context context)

Uses of Event in org.apache.flink.cdc.connectors.values.source

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

Modifier and Type	Method	Description
static List<List<Event>>	ValuesDataSourceHelper.appendOnlyBlobTable()
static List<List<Event>>	ValuesDataSourceHelper.complexColumnNameTable()
static List<List<Event>>	ValuesDataSourceHelper.getSourceEvents()
static List<List<Event>>	ValuesDataSourceHelper.multiSplitSingleBatchTable()
static List<List<Event>>	ValuesDataSourceHelper.multiSplitsSingleTable()
static List<List<Event>>	ValuesDataSourceHelper.singleSplitMultiBatchTable()
static List<List<Event>>	ValuesDataSourceHelper.singleSplitMultiTables()
static List<List<Event>>	ValuesDataSourceHelper.singleSplitSingleBatchTable()
static List<List<Event>>	ValuesDataSourceHelper.singleSplitSinglePartitionTable()	A single split with a single partitioned table.
static List<List<Event>>	ValuesDataSourceHelper.singleSplitSingleTable()
static List<List<Event>>	ValuesDataSourceHelper.singleSplitSingleTableWithDefaultValue()
static List<List<Event>>	ValuesDataSourceHelper.transformBatchTable()
static List<List<Event>>	ValuesDataSourceHelper.transformTable()

Method parameters in org.apache.flink.cdc.connectors.values.source with type arguments of type Event

Modifier and Type	Method	Description
static void	ValuesDataSourceHelper.setSourceEvents(List<List<Event>> customSourceEvents)	set sourceEvents using custom events.

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

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

Modifier and Type	Method	Description
List<? extends Event>	SourceRecordEventDeserializer.deserialize(org.apache.kafka.connect.source.SourceRecord record)
org.apache.flink.api.common.typeinfo.TypeInformation<Event>	DebeziumEventDeserializationSchema.getProducedType()

Method parameters in org.apache.flink.cdc.debezium.event with type arguments of type Event

Modifier and Type	Method	Description
void	DebeziumEventDeserializationSchema.deserialize(org.apache.kafka.connect.source.SourceRecord record, org.apache.flink.util.Collector<Event> out)

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

Method parameters in org.apache.flink.cdc.runtime.operators.schema.distributed with type arguments of type Event

Modifier and Type	Method	Description
void	SchemaOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event>> output)

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

Method parameters in org.apache.flink.cdc.runtime.operators.schema.regular with type arguments of type Event

Modifier and Type	Method	Description
void	BatchSchemaOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> streamRecord)	This method is guaranteed to not be called concurrently with other methods of the operator.
void	SchemaOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> streamRecord)	This method is guaranteed to not be called concurrently with other methods of the operator.
void	BatchSchemaOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event>> output)
void	SchemaOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event>> output)

Uses of Event in org.apache.flink.cdc.runtime.operators.sink

Method parameters in org.apache.flink.cdc.runtime.operators.sink with type arguments of type Event

Modifier and Type	Method	Description
void	BatchDataSinkFunctionOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)
void	BatchDataSinkWriterOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)
void	DataSinkFunctionOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)
void	DataSinkWriterOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)

Constructor parameters in org.apache.flink.cdc.runtime.operators.sink with type arguments of type Event

Constructor	Description
BatchDataSinkFunctionOperator(org.apache.flink.streaming.api.functions.sink.SinkFunction<Event> userFunction)
BatchDataSinkWriterOperator(org.apache.flink.api.connector.sink2.Sink<Event> sink, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService, org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor)
DataSinkFunctionOperator(org.apache.flink.streaming.api.functions.sink.SinkFunction<Event> userFunction, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID)
DataSinkWriterOperator(org.apache.flink.api.connector.sink2.Sink<Event> sink, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService, org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID)
DataSinkWriterOperatorFactory(org.apache.flink.api.connector.sink2.Sink<Event> sink, boolean isBounded, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID)

Uses of Event in org.apache.flink.cdc.runtime.operators.sink.exception

Constructors in org.apache.flink.cdc.runtime.operators.sink.exception with parameters of type Event

Constructor	Description
SinkWrapperException(Event event, Throwable cause)

Uses of Event in org.apache.flink.cdc.runtime.operators.transform

Method parameters in org.apache.flink.cdc.runtime.operators.transform with type arguments of type Event

Modifier and Type	Method	Description
void	PostTransformOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)
void	PreTransformOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)
void	PreTransformOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event>> output)

Uses of Event in org.apache.flink.cdc.runtime.operators.transform.async

Methods in org.apache.flink.cdc.runtime.operators.transform.async with type parameters of type Event

Modifier and Type	Method	Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<Event>> T	AsyncPostTransformOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Event> parameters)

Methods in org.apache.flink.cdc.runtime.operators.transform.async with parameters of type Event

Modifier and Type	Method	Description
void	AsyncPostTransformFunction.asyncInvoke(Event event, org.apache.flink.streaming.api.functions.async.ResultFuture<Event> resultFuture)
void	AsyncPostTransformFunction.timeout(Event event, org.apache.flink.streaming.api.functions.async.ResultFuture<Event> resultFuture)

Method parameters in org.apache.flink.cdc.runtime.operators.transform.async with type arguments of type Event

Modifier and Type	Method	Description
void	AsyncPostTransformFunction.asyncInvoke(Event event, org.apache.flink.streaming.api.functions.async.ResultFuture<Event> resultFuture)
<T extends org.apache.flink.streaming.api.operators.StreamOperator<Event>> T	AsyncPostTransformOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Event> parameters)
void	AsyncPostTransformFunction.timeout(Event event, org.apache.flink.streaming.api.functions.async.ResultFuture<Event> resultFuture)

Uses of Event in org.apache.flink.cdc.runtime.operators.transform.exceptions

Methods in org.apache.flink.cdc.runtime.operators.transform.exceptions with parameters of type Event

Modifier and Type	Method	Description
static String	TransformException.prettyPrintEvent(Event event, Schema schema)

Constructors in org.apache.flink.cdc.runtime.operators.transform.exceptions with parameters of type Event

Constructor	Description
TransformException(String command, Event event, TableId tableId, Schema schemaBefore, Schema schemaAfter, Throwable cause)

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

Classes in org.apache.flink.cdc.runtime.partitioning that implement Event

Modifier and Type	Class	Description
class	PartitioningEvent	A wrapper around Event, which contains the target partition number and will be used in EventPartitioner.

Methods in org.apache.flink.cdc.runtime.partitioning that return Event

Modifier and Type	Method	Description
Event	PartitioningEvent.getPayload()
Event	PostPartitionProcessor.map(PartitioningEvent value)

Methods in org.apache.flink.cdc.runtime.partitioning with parameters of type Event

Modifier and Type	Method	Description
static PartitioningEvent	PartitioningEvent.ofDistributed(Event payload, int sourcePartition, int targetPartition)	For distributed topology, we need to track its upstream source subTask ID to correctly distinguish events from different partitions.
static PartitioningEvent	PartitioningEvent.ofRegular(Event payload, int targetPartition)	For partitioning events with regular topology, source partition information is not necessary.

Method parameters in org.apache.flink.cdc.runtime.partitioning with type arguments of type Event

Modifier and Type	Method	Description
void	BatchRegularPrePartitionOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)
void	DistributedPrePartitionOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)
void	RegularPrePartitionOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Event> element)

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

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

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

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

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

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

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

Uses of Event in org.apache.flink.cdc.runtime.typeutils

Methods in org.apache.flink.cdc.runtime.typeutils that return types with arguments of type Event

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializer<Event>	EventTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig config)
org.apache.flink.api.common.typeutils.TypeSerializer<Event>	EventTypeInfo.createSerializer(org.apache.flink.api.common.serialization.SerializerConfig config)	For Flink 2.2+ (TypeInformation.createSerializer now takes SerializerConfig).
Class<Event>	EventTypeInfo.getTypeClass()