Package org.apache.flink.cdc.connectors.paimon.sink

Class PaimonHashFunction

java.lang.Object

org.apache.flink.cdc.connectors.paimon.sink.PaimonHashFunction

All Implemented Interfaces:

Serializable, HashFunction<DataChangeEvent>

public class PaimonHashFunction
extends Object
implements HashFunction<DataChangeEvent>, Serializable

A HashFunction implementation for PaimonDataSink. Shuffle DataChangeEvent by hash of PrimaryKey.

Table type (append-only vs. primary-key) is inferred directly from the CDC Schema instead of querying the Paimon catalog. This avoids a TableNotExistException when the target table has not yet been created by MetadataApplier, which can happen in distributed pipeline topologies where pre-partitioning precedes schema coordination.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.cdc.common.function.HashFunction

HashFunction.HashContext

Constructor Summary

Constructors

Constructor	Description
PaimonHashFunction(Schema schema, java.time.ZoneId zoneId, int parallelism)

Method Summary

Modifier and Type	Method	Description
int	hashcode(DataChangeEvent event)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.cdc.common.function.HashFunction

hashcode

Constructor Detail

PaimonHashFunction

public PaimonHashFunction(Schema schema,
                          java.time.ZoneId zoneId,
                          int parallelism)

Method Detail

hashcode

public int hashcode(DataChangeEvent event)

Specified by:

hashcode in interface HashFunction<DataChangeEvent>