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

Class FlussDataSink

java.lang.Object

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

All Implemented Interfaces:

DataSink

public class FlussDataSink
extends Object
implements DataSink

A DataSink implementation for Fluss.

Constructor Summary

Constructors

Constructor	Description
FlussDataSink(org.apache.fluss.config.Configuration flussClientConfig, Map<String,String> tableProperties, Map<String,List<String>> bucketKeysMap, Map<String,Integer> bucketNumMap, FlussDataSinkOptions.SinkPartitioningStrategy sinkPartitioningStrategy)

Method Summary

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	getDataChangeEventHashFunctionProvider()	Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.
EventSinkProvider	getEventSinkProvider()	Get the EventSinkProvider for writing changed data to external systems.
MetadataApplier	getMetadataApplier()	Get the MetadataApplier for applying metadata changes to external systems.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.cdc.common.sink.DataSink

getDataChangeEventHashFunctionProvider

Constructor Detail

FlussDataSink

public FlussDataSink(org.apache.fluss.config.Configuration flussClientConfig,
                     Map<String,String> tableProperties,
                     Map<String,List<String>> bucketKeysMap,
                     Map<String,Integer> bucketNumMap,
                     FlussDataSinkOptions.SinkPartitioningStrategy sinkPartitioningStrategy)

Method Detail

getEventSinkProvider

public EventSinkProvider getEventSinkProvider()

Description copied from interface: DataSink

Get the EventSinkProvider for writing changed data to external systems.

Specified by:

getEventSinkProvider in interface DataSink

getMetadataApplier

public MetadataApplier getMetadataApplier()

Description copied from interface: DataSink

Get the MetadataApplier for applying metadata changes to external systems.

Specified by:

getMetadataApplier in interface DataSink

getDataChangeEventHashFunctionProvider

public HashFunctionProvider<DataChangeEvent> getDataChangeEventHashFunctionProvider()

Description copied from interface: DataSink

Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.

Specified by:

getDataChangeEventHashFunctionProvider in interface DataSink