org.apache.flink.cdc.common.sink

接口 DataSink

@PublicEvolving
public interface DataSink

DataSink is used to write change data to external system and apply metadata changes to external systems as well.

方法概要

限定符和类型	方法和说明
default HashFunctionProvider<DataChangeEvent>	getDataChangeEventHashFunctionProvider() Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.
default 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.

方法详细资料

getEventSinkProvider

EventSinkProvider getEventSinkProvider()

Get the EventSinkProvider for writing changed data to external systems.

getMetadataApplier

MetadataApplier getMetadataApplier()

Get the MetadataApplier for applying metadata changes to external systems.

getDataChangeEventHashFunctionProvider

default HashFunctionProvider<DataChangeEvent> getDataChangeEventHashFunctionProvider()

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

getDataChangeEventHashFunctionProvider

default HashFunctionProvider<DataChangeEvent> getDataChangeEventHashFunctionProvider(int parallelism)