Uses of Interface
org.apache.flink.cdc.common.function.HashFunction

Packages that use HashFunction

Package	Description
org.apache.flink.cdc.common.function
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.maxcompute.sink
org.apache.flink.cdc.connectors.paimon.sink

Uses of HashFunction in org.apache.flink.cdc.common.function

Methods in org.apache.flink.cdc.common.function that return HashFunction

Modifier and Type	Method	Description
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.

Uses of HashFunction in org.apache.flink.cdc.common.sink

Methods in org.apache.flink.cdc.common.sink that return HashFunction

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	DefaultDataChangeEventHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
HashFunction<DataChangeEvent>	ForwardHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
HashFunction<DataChangeEvent>	TableIdHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

Uses of HashFunction in org.apache.flink.cdc.connectors.fluss.sink

Methods in org.apache.flink.cdc.connectors.fluss.sink that return HashFunction

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	FlussHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

Uses of HashFunction in org.apache.flink.cdc.connectors.maxcompute.sink

Methods in org.apache.flink.cdc.connectors.maxcompute.sink that return HashFunction

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	MaxComputeHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

Uses of HashFunction in org.apache.flink.cdc.connectors.paimon.sink

Classes in org.apache.flink.cdc.connectors.paimon.sink that implement HashFunction

Modifier and Type	Class	Description
class	PaimonHashFunction	A HashFunction implementation for PaimonDataSink.

Methods in org.apache.flink.cdc.connectors.paimon.sink that return HashFunction

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	PaimonHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)