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

Class PaimonHashFunctionProvider

java.lang.Object

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

All Implemented Interfaces:

Serializable, HashFunctionProvider<DataChangeEvent>

public class PaimonHashFunctionProvider
extends Object
implements HashFunctionProvider<DataChangeEvent>

A HashFunctionProvider implementation for PaimonDataSink.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
PaimonHashFunctionProvider(java.time.ZoneId zoneId, int parallelism)

Method Summary

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	getHashFunction(TableId tableId, Schema schema)	Gets a hash function based on the given table ID and schema, to help PrePartitionOperator to shuffle DataChangeEvent to designated subtask.

Methods inherited from class java.lang.Object

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

Constructor Detail

PaimonHashFunctionProvider

public PaimonHashFunctionProvider(java.time.ZoneId zoneId,
                                  int parallelism)

Method Detail

getHashFunction

public HashFunction<DataChangeEvent> getHashFunction(@Nullable
                                                     TableId tableId,
                                                     Schema schema)

Description copied from interface: HashFunctionProvider

Gets a hash function based on the given table ID and schema, to help PrePartitionOperator to shuffle DataChangeEvent to designated subtask.

Specified by:

getHashFunction in interface HashFunctionProvider<DataChangeEvent>

Parameters:

tableId - table ID

schema - flink table schema

Returns:

hash function based on the given table ID and schema