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
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)