Hi, You get that by having the two input streams keyed on the same key. Either by doing keyBy() on them individually or by using keyBy() on the ConnectedStream.
Best, Aljoscha > On 3. May 2017, at 13:06, Tarek khal-letaief <tarek.khal.leta...@gmail.com> > wrote: > > Hi Aljoscha, > Thanks for reply. > > I opted for the first solution: to use a connected FlatMap [1] but how i can > simulate the while(key) and the equalTo(key) of a "join" because the function > gets individual calls to flatMap1 and flatMap2. > > Best regards, > Tarek, > > 2017-05-03 10:18 GMT+01:00 Aljoscha Krettek <aljos...@apache.org > <mailto:aljos...@apache.org>>: > Hi, > Instead of a Join, I would suggest to use a connected FlatMap [1] (or a > connected ProcessFunction [2]). The problem with a join is that the rules > only “survive” for the length of the window while I suspect that you want > them to survive longer than that so that they can be applied to events > arriving in the future. > > Best, > Aljoscha > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html#datastream-transformations > > <https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html#datastream-transformations> > [2] > https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/stream/process_function.html#low-level-joins > > <https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/stream/process_function.html#low-level-joins> > >> On 2. May 2017, at 18:58, Tarek khal <tarek.khal.leta...@gmail.com >> <mailto:tarek.khal.leta...@gmail.com>> wrote: >> >> I have two kafka topics (tracking and rules) and I would like to join >> "tracking" datastream with "rules" datastream as the data arrives in the >> "tracking" datastream. >> >> >> Here the result that I expect, but without restarting the Job, here I >> restarted the Job to get this result: >> >> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/n12954/Capture.jpg >> >> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/n12954/Capture.jpg>> >> >> >> Code: >> >> >> >> >> >> -- >> View this message in context: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Join-two-kafka-topics-tp12954.html >> >> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Join-two-kafka-topics-tp12954.html> >> Sent from the Apache Flink User Mailing List archive. mailing list archive >> at Nabble.com <http://nabble.com/>. > > > > > -- > Tarek KHAL LETAIEF
