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

java.lang.Object
- org.apache.flink.cdc.connectors.elasticsearch.sink.ElasticsearchDataSink<InputT>

Type Parameters:

InputT - The type of input elements that this sink can process.

All Implemented Interfaces:

Serializable, DataSink
```
public class ElasticsearchDataSink<InputT>
extends Object
implements DataSink, Serializable
```
An implementation of DataSink for writing events to Elasticsearch.
This class is responsible for configuring and managing the lifecycle of an Elasticsearch sink, including handling different versions of Elasticsearch (6, 7, 8).

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor	Description
`ElasticsearchDataSink(ElasticsearchSinkOptions elasticsearchOptions, java.time.ZoneId zoneId)`	Constructs an ElasticsearchDataSink with the given options and time zone.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`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, getDataChangeEventHashFunctionProvider

- Constructor Detail
  - ElasticsearchDataSink
```
public ElasticsearchDataSink(ElasticsearchSinkOptions elasticsearchOptions,
                             java.time.ZoneId zoneId)
```
    Constructs an ElasticsearchDataSink with the given options and time zone.
    
    Parameters:
    
    elasticsearchOptions - The Elasticsearch sink options.
    
    zoneId - The time zone ID for handling time-related operations.
- 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