Re: Joining two aggregated streams

2017-07-14 Thread Udhay
Hi Thanks for your suggestion. I ll try this one.:) -Udhay. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Joining-two-aggregated-streams-tp14123p14289.html Sent from the Apache Flink User Mailing List archive. mailing list archive at

Joining two aggregated streams

2017-07-05 Thread Udhay
I was trying to join two keyed streams in a particular way and get a combined stream. For example: Lets say I call the two streams as X and Y. The X stream contains: (Key,Value) (A,P) (A,Q) (A,R) (B,P) (C,P) (C,Q) The Y stream contains: (Key,Value,Flag1,Flag2) (A,M1,0,0) (A,M2,0,0) (A,M3,1,0)