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

Packages that use HashFunctionProvider

Package	Description
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.maxcompute
org.apache.flink.cdc.connectors.maxcompute.sink
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.runtime.partitioning

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

Classes in org.apache.flink.cdc.common.sink that implement HashFunctionProvider

Modifier and Type	Class	Description
class	DefaultDataChangeEventHashFunctionProvider	The default HashFunctionProvider implementation for data change event.
class	ForwardHashFunctionProvider	A HashFunctionProvider that preserves the upstream subtask distribution.
class	TableIdHashFunctionProvider	A HashFunctionProvider implementation that hashes events based solely on TableId.

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

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

Uses of HashFunctionProvider in org.apache.flink.cdc.composer.flink.translator

Methods in org.apache.flink.cdc.composer.flink.translator with parameters of type HashFunctionProvider

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<PartitioningEvent>	PartitioningTranslator.translateDistributed(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int upstreamParallelism, int downstreamParallelism, HashFunctionProvider<DataChangeEvent> hashFunctionProvider)
org.apache.flink.streaming.api.datastream.DataStream<Event>	PartitioningTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int upstreamParallelism, int downstreamParallelism, boolean isBatchMode, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, HashFunctionProvider<DataChangeEvent> hashFunctionProvider, OperatorUidGenerator operatorUidGenerator)
org.apache.flink.streaming.api.datastream.DataStream<Event>	PartitioningTranslator.translateRegular(org.apache.flink.streaming.api.datastream.DataStream<Event> input, int upstreamParallelism, int downstreamParallelism, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID, HashFunctionProvider<DataChangeEvent> hashFunctionProvider, OperatorUidGenerator operatorUidGenerator)

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

Classes in org.apache.flink.cdc.connectors.fluss.sink that implement HashFunctionProvider

Modifier and Type	Class	Description
class	FlussHashFunctionProvider	HashFunctionProvider implementation for FlussDataSink.

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

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	FlussDataSink.getDataChangeEventHashFunctionProvider()

Uses of HashFunctionProvider in org.apache.flink.cdc.connectors.maxcompute

Methods in org.apache.flink.cdc.connectors.maxcompute that return HashFunctionProvider

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	MaxComputeDataSink.getDataChangeEventHashFunctionProvider()

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

Classes in org.apache.flink.cdc.connectors.maxcompute.sink that implement HashFunctionProvider

Modifier and Type	Class	Description
class	MaxComputeHashFunctionProvider	Hash function for maxcompute to distribute data change event to different maxcompute sink by primary key.

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

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

Modifier and Type	Class	Description
class	PaimonHashFunctionProvider	A HashFunctionProvider implementation for PaimonDataSink.

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

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	PaimonDataSink.getDataChangeEventHashFunctionProvider(int parallelism)

Uses of HashFunctionProvider in org.apache.flink.cdc.runtime.partitioning

Constructors in org.apache.flink.cdc.runtime.partitioning with parameters of type HashFunctionProvider

Constructor	Description
BatchRegularPrePartitionOperator(int downstreamParallelism, HashFunctionProvider<DataChangeEvent> hashFunctionProvider)
DistributedPrePartitionOperator(int downstreamParallelism, HashFunctionProvider<DataChangeEvent> hashFunctionProvider)
RegularPrePartitionOperator(org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorId, int downstreamParallelism, HashFunctionProvider<DataChangeEvent> hashFunctionProvider)