Hi. 

I have an existing Flink job in 2.0 and want to extend the job with some of the 
functionality in the new data stream api. 

In order to do that without rewriting the entire job I was hoping to find a 
method that could convert a DataStream into a NonKeyedPartitionStream. 

1. Is it possible to do that conversion? 
2. Can Flink handle both types of streams in the same job?

Please let me know. 

Best regards
Lasse Nedergaard

Reply via email to