Package org.apache.flink.cdc.connectors.fluss.sink

Class FlussHashFunctionProvider

java.lang.Object

org.apache.flink.cdc.connectors.fluss.sink.FlussHashFunctionProvider

All Implemented Interfaces:

Serializable, HashFunctionProvider<DataChangeEvent>

public class FlussHashFunctionProvider
extends Object
implements HashFunctionProvider<DataChangeEvent>

HashFunctionProvider implementation for FlussDataSink.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlussHashFunctionProvider()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FlussHashFunctionProvider

public FlussHashFunctionProvider()

Method Detail

getHashFunction

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

Description copied from interface: HashFunctionProvider

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

Specified by:

getHashFunction in interface HashFunctionProvider<DataChangeEvent>

Parameters:

tableId - table ID

schema - flink table schema

Returns:

hash function based on the given table ID and schema