Hi nragon, apparently I didn't read the P.S. since I assumed its not important. Silly me.
So you are trying to join stream A and B to stream C with stream A and B being keyed. Alright. Are how often do matching elements (matched by primary key) from A and B arrive on your operator to-be-implemented? This question can't be universially answered without having some more constraints on the streams A and B. To me this sounds more like a batch job because it needs to have the whole stream A or B in memory in order to join every element. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Related-datastream-tp13901p13904.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
