org.apache.flink.cdc.common.sink

类 DefaultDataChangeEventHashFunctionProvider

java.lang.Object

org.apache.flink.cdc.common.sink.DefaultDataChangeEventHashFunctionProvider

所有已实现的接口:

Serializable, HashFunctionProvider<DataChangeEvent>

public class DefaultDataChangeEventHashFunctionProvider
extends Object
implements HashFunctionProvider<DataChangeEvent>

The default HashFunctionProvider implementation for data change event.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
DefaultDataChangeEventHashFunctionProvider()

方法概要

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

从类继承的方法 java.lang.Object

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

构造器详细资料

DefaultDataChangeEventHashFunctionProvider

public DefaultDataChangeEventHashFunctionProvider()

方法详细资料

getHashFunction

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

从接口复制的说明: HashFunctionProvider

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

指定者:

getHashFunction 在接口中 HashFunctionProvider<DataChangeEvent>

参数:

tableId - table ID

schema - flink table schema

返回:

hash function based on the given table ID and schema