Hi Lian Jiang,
Both two solutions have its advantage and disadvantages.
Solution 1:
advantage:
1. Code is simple. The multiple join operator decides that join
sequence, which means the only (A,B) could output the streamA_B_C and
only (A,B,C) could output the streamA_B_C_D. BTW, this
Hi,
Imagine I have one class having 4 fields: ID, A, B, C. There are three
data sources providing data in the form of (ID, A), (ID, B), (ID, C)
respectively. I want to join these three data sources to get final (ID, A,
B, C) without any window. For example, (ID, A) could come one month after