People, I have two sources:
1) DataStream<Integer> int1 = env.addSource(new intWithDelat1()): generates series of integers in streaming of 1 sec delay between elemets. 2) DataStream<Long> long3 = env.addSource(new longWithDelay3()): generates series of longs in streaming of 3 sec delay. I want to: int1.connect(long3).flatMap(new printElemnts()); I want this transformation to be synchronized so that element from source 1 will be read only when the equivalent element from source 2 comes: 1 1 2 2 3 3 … And not: 1 1 2 3 2 4 5 … any way to do that? (advanced: why things not similar to the example in 'notions of time' <https://www.youtube.com/watch?v=xiKsOocNkDA> at 11:20?) Thanks -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Sync-Flink-tp19403.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
