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

Class ElasticsearchEventSerializer

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.flink.connector.base.sink.writer.ElementConverter<Event,co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant>

public class ElasticsearchEventSerializer
extends Object
implements org.apache.flink.connector.base.sink.writer.ElementConverter<Event,co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant>

A serializer for Event to BulkOperationVariant.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static java.time.format.DateTimeFormatter	DATE_FORMATTER	Format DATE type data.
static java.time.format.DateTimeFormatter	DATE_TIME_FORMATTER	Format timestamp-related type data.

Constructor Summary

Constructors

Constructor	Description
ElasticsearchEventSerializer(java.time.ZoneId zoneId)
ElasticsearchEventSerializer(java.time.ZoneId zoneId, Map<TableId,String> shardingKey, String shardingSeparator)

Method Summary

Modifier and Type	Method	Description
co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant	apply(Event event, org.apache.flink.api.connector.sink2.SinkWriter.Context context)
Map<String,Object>	serializeRecord(TableId tableId, RecordData recordData, Schema schema, java.time.ZoneId pipelineZoneId)
String	tableSharding(TableId tableId, Schema schema, Map<String,Object> valueMap)

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.connector.base.sink.writer.ElementConverter

open

Field Detail

DATE_FORMATTER

public static final java.time.format.DateTimeFormatter DATE_FORMATTER

Format DATE type data.

DATE_TIME_FORMATTER

public static final java.time.format.DateTimeFormatter DATE_TIME_FORMATTER

Format timestamp-related type data.

Constructor Detail

ElasticsearchEventSerializer

public ElasticsearchEventSerializer(java.time.ZoneId zoneId)

ElasticsearchEventSerializer

public ElasticsearchEventSerializer(java.time.ZoneId zoneId,
                                    Map<TableId,String> shardingKey,
                                    String shardingSeparator)

Method Detail

apply

public co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant apply(Event event,
                                                                             org.apache.flink.api.connector.sink2.SinkWriter.Context context)

Specified by:

apply in interface org.apache.flink.connector.base.sink.writer.ElementConverter<Event,co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant>

tableSharding

public String tableSharding(TableId tableId,
                            Schema schema,
                            Map<String,Object> valueMap)

serializeRecord

public Map<String,Object> serializeRecord(TableId tableId,
                                                RecordData recordData,
                                                Schema schema,
                                                java.time.ZoneId pipelineZoneId)