ElementConverter (Flink : 2.0-SNAPSHOT API)

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

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`RequestEntryT`	`apply(InputT element, SinkWriter.Context context)`
`default void`	`open(WriterInitContext context)`

Method Detail

apply

RequestEntryT apply(InputT element,
                    SinkWriter.Context context)

open

default void open(WriterInitContext context)