Uses of Class
org.apache.flink.cdc.runtime.partitioning.PartitioningEvent

Packages that use PartitioningEvent

Package	Description
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.runtime.operators.schema.distributed
org.apache.flink.cdc.runtime.partitioning
org.apache.flink.cdc.runtime.serializer.event
org.apache.flink.cdc.runtime.typeutils

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

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

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)

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

Modifier and Type	Method	Description
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)

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

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

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

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

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.

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

Modifier and Type	Method	Description
Integer	PartitioningEventKeySelector.getKey(PartitioningEvent event)
Event	PostPartitionProcessor.map(PartitioningEvent value)

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

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

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

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

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

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

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

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

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

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