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 <mohitanch...@gmail.com>: > 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, 刘彪 <mmyy1...@gmail.com> wrote: > >> 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, I think you can add a SerializationSchema interface in >> SinkFunction. And user have to implement the SerializationSchema, maybe >> named Tuple2SerializationSchema. >> >> 2017-02-22 7:17 GMT+08:00 Mohit Anchlia <mohitanch...@gmail.com>: >> >>> 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? >>> >> >> >
