Package org.apache.flink.cdc.connectors.elasticsearch.serializer

Interface ElasticsearchRowConverter.SerializationConverter

Enclosing class:

ElasticsearchRowConverter

public static interface ElasticsearchRowConverter.SerializationConverter

Interface for serialization converters.

Method Summary

Modifier and Type	Method	Description
Object	serialize(int pos, RecordData data)	Serializes a value from the given position in the RecordData.

Method Detail

serialize

Object serialize(int pos,
                 RecordData data)

Serializes a value from the given position in the RecordData.

Parameters:

pos - The position of the value in the RecordData.

data - The RecordData containing the value to serialize.

Returns:

The serialized object.