接口的使用
org.apache.flink.cdc.common.function.HashFunction

使用HashFunction的程序包

程序包	说明
org.apache.flink.cdc.common.function
org.apache.flink.cdc.common.sink

org.apache.flink.cdc.common.function中HashFunction的使用

返回HashFunction的org.apache.flink.cdc.common.function中的方法

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

org.apache.flink.cdc.common.sink中HashFunction的使用

返回HashFunction的org.apache.flink.cdc.common.sink中的方法

限定符和类型	方法和说明
HashFunction<DataChangeEvent>	DefaultDataChangeEventHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)