org.apache.flink.cdc.common.function

接口 HashFunctionProvider<T>

类型参数:

T - the type of given element

所有超级接口:

Serializable

所有已知实现类:

DefaultDataChangeEventHashFunctionProvider

@Internal
public interface HashFunctionProvider<T>
extends Serializable

Provider that provides HashFunction to help PrePartitionOperator to shuffle event to designated subtask. This is usually beneficial for load balancing, when writing to different partitions/buckets in DataSink, add custom implementation to further improve efficiency.

方法概要

限定符和类型	方法和说明
HashFunction<T>	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.

方法详细资料

getHashFunction

HashFunction<T> getHashFunction(@Nullable
                                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.

参数:

tableId - table ID

schema - flink table schema

返回:

hash function based on the given table ID and schema