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

使用HashFunctionProvider的程序包

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

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

实现HashFunctionProvider的org.apache.flink.cdc.common.sink中的类

限定符和类型	类和说明
class	DefaultDataChangeEventHashFunctionProvider The default HashFunctionProvider implementation for data change event.

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

限定符和类型	方法和说明
default HashFunctionProvider<DataChangeEvent>	DataSink.getDataChangeEventHashFunctionProvider() Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.
default HashFunctionProvider<DataChangeEvent>	DataSink.getDataChangeEventHashFunctionProvider(int parallelism)