I have DataStream, is there a way to convert it DataSet or table so that I
could sort it and persist it a file?
Thanks a lot!
ingle default target topic, and in
`KeyedSerializationSchema#getTargetTopic()` you can override the default topic
with whatever is returned. The `getTargetTopic` method is invoked for each
record.
Cheers,Gordon
On 6 July 2017 at 9:09:29 AM, Richard Xin (richardxin...@yahoo.com) wrote:
when using FlinkKafkaConsumer010 to subscribing multiple topics as
List topics = Arrays.asList("test1","test2");
DataStream stream = env.addSource(new FlinkKafkaConsumer010<>(topics,
new SimpleStringSchema(), properties));
How do I get topic names in my SinkFunction? i.e. stream.addSink()
Thanks,
