Package org.apache.flink.cdc.common.sink

Class TableIdHashFunctionProvider

java.lang.Object

org.apache.flink.cdc.common.sink.TableIdHashFunctionProvider

All Implemented Interfaces:

Serializable, HashFunctionProvider<DataChangeEvent>

public class TableIdHashFunctionProvider
extends Object
implements HashFunctionProvider<DataChangeEvent>

A HashFunctionProvider implementation that hashes events based solely on TableId.

This provider ensures all events from the same table are routed to the same downstream subtask, regardless of their primary key values or record payload. The hash is computed once when the HashFunction is created and cached for all subsequent events.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
TableIdHashFunctionProvider()

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

TableIdHashFunctionProvider

public TableIdHashFunctionProvider()

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