RE: Equivalent of Rx combineLatest() on a join?

2016-12-13 Thread denis.dollfus
to dig further in this direction. Regards, Denis -Original Message- From: Gábor Gévay [mailto:gga...@gmail.com] Sent: mardi 13 décembre 2016 09:45 To: user@flink.apache.org Subject: Re: Equivalent of Rx combineLatest() on a join? Dear Denis, I think you can do it with a simple

Re: Equivalent of Rx combineLatest() on a join?

2016-12-13 Thread Gábor Gévay
If the goal is not clear I can > provide more details. > > > > Thank you, > > > > Denis > > > > From: Dollfus, Denis (TR Technology & Ops) > Sent: lundi 5 décembre 2016 16:31 > To: user@flink.apache.org > Subject: RE: Equivalent of Rx combineLatest() on

RE: Equivalent of Rx combineLatest() on a join?

2016-12-05 Thread denis.dollfus
. If the goal is not clear I can provide more details. Thank you, Denis From: Dollfus, Denis (TR Technology & Ops) Sent: lundi 5 décembre 2016 16:31 To: user@flink.apache.org Subject: RE: Equivalent of Rx combineLatest() on a join? Asking the response helped me to find the answer (yes, rubber

Equivalent of Rx combineLatest() on a join?

2016-12-05 Thread denis.dollfus
Hi all, [first email here, I'm new to Flink, Java and Scala, sorry if I missed something obvious] I'm exploring Flink in the context of streaming calculators. Basically, the data flow boils down to multiple data streams with variable update rates (ms, seconds, ..., month) which are joined