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

Class PaimonDataSink

java.lang.Object

org.apache.flink.cdc.connectors.paimon.sink.PaimonDataSink

All Implemented Interfaces:

Serializable, DataSink

public class PaimonDataSink
extends Object
implements DataSink, Serializable

A DataSink for Paimon connector that supports schema evolution.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
String	schemaOperatorUid

Constructor Summary

Constructors

Constructor	Description
PaimonDataSink(org.apache.paimon.options.Options options, Map<String,String> tableOptions, String commitUser, Map<TableId,List<String>> partitionMaps, PaimonRecordSerializer<Event> serializer, java.time.ZoneId zoneId, String schemaOperatorUid)

Method Summary

Modifier and Type	Method	Description
HashFunctionProvider<DataChangeEvent>	getDataChangeEventHashFunctionProvider(int parallelism)
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

Field Detail

schemaOperatorUid

public final String schemaOperatorUid

Constructor Detail

PaimonDataSink

public PaimonDataSink(org.apache.paimon.options.Options options,
                      Map<String,String> tableOptions,
                      String commitUser,
                      Map<TableId,List<String>> partitionMaps,
                      PaimonRecordSerializer<Event> serializer,
                      java.time.ZoneId zoneId,
                      String schemaOperatorUid)

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(int parallelism)

Specified by:

getDataChangeEventHashFunctionProvider in interface DataSink