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

java.lang.Object
- org.apache.flink.cdc.connectors.elasticsearch.serializer.ElasticsearchRowConverter

```
public class ElasticsearchRowConverter
extends Object
```
Converter class for serializing row data to Elasticsearch compatible formats.

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static interface ElasticsearchRowConverter.SerializationConverter
Interface for serialization converters.

Constructor Summary

Constructors
Constructor Description

ElasticsearchRowConverter()

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static ElasticsearchRowConverter.SerializationConverter`	`createNullableExternalConverter(DataType columnType, java.time.ZoneId zoneId)`	Creates a nullable external converter for the given column type and time zone.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ElasticsearchRowConverter
```
public ElasticsearchRowConverter()
```
- Method Detail
  - createNullableExternalConverter
```
public static ElasticsearchRowConverter.SerializationConverter createNullableExternalConverter(DataType columnType,
                                                                                               java.time.ZoneId zoneId)
```
    Creates a nullable external converter for the given column type and time zone.
    
    Parameters:
    
    columnType - The type of the column to convert.
    
    zoneId - The time zone to use for temporal conversions.
    
    Returns:
    
    A SerializationConverter that can handle null values.