DataSink (flink-cdc-parent 3.8-SNAPSHOT API)

All Known Implementing Classes:

DorisDataSink, ElasticsearchDataSink, FlussDataSink, HudiDataSink, IcebergDataSink, KafkaDataSink, MaxComputeDataSink, OceanBaseDataSink, PaimonDataSink, StarRocksDataSink, ValuesDataSink
```
@PublicEvolving
public interface DataSink
```
DataSink is used to write change data to external system and apply metadata changes to external systems as well.

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`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.

- Method Detail
  - 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)
```