org.apache.flink.connector.base.sink.writer

Interface ElementConverter<InputT,RequestEntryT>

All Superinterfaces:

Serializable

@PublicEvolving
public interface ElementConverter<InputT,RequestEntryT>
extends Serializable

This interface specifies the mapping between elements of a stream to request entries that can be sent to the destination. The mapping is provided by the end-user of a sink, not the sink creator.

The request entries contain all relevant information required to create and sent the actual request. Eg, for Kinesis Data Streams, the request entry includes the payload and the partition key.

Method Summary

Modifier and Type	Method and Description
RequestEntryT	apply(InputT element, SinkWriter.Context context)
default void	open(Sink.InitContext context)

Method Detail

apply

RequestEntryT apply(InputT element,
                    SinkWriter.Context context)

open

default void open(Sink.InitContext context)