Hi Mohit,
I don’t completely understand your question, but I’m assuming that you know the
type of records your custom sink will be receiving, but you don’t know how to
extract values from the records.
Assume that the type of the incoming records will be `Tuple2`.
When writing your custom sink,
Currently, OutputFormat is used for DataSet, SinkFunction is used for
DataStream. Maybe I misunderstand your problem. That will be better if you
give more details.
2017-02-24 5:21 GMT+08:00 Mohit Anchlia :
> This works for Kafka but for the other types of sink am I supposed to use
> some type of
This works for Kafka but for the other types of sink am I supposed to use
some type of outputformat?
On Tue, Feb 21, 2017 at 7:13 PM, 刘彪 wrote:
> Hi
> I think there is a good way in FlinkKafkaProducerBase.java to deal with
> this situation. There is a KeyedSerializationSchema user have to implem
Hi
I think there is a good way in FlinkKafkaProducerBase.java to deal with
this situation. There is a KeyedSerializationSchema user have to implement.
KeyedSerializationSchema will be used to serialize data, so that
SinkFunction just need to understand the type after serialization.
In your case,
What's the best way to retrieve both the values in Tuple2 inside a custom
sink given that the type is not known inside the sink function?
