Hi , I'm currently working on Flink with a simple stock market 
analysis.Basically i need to have the sum of 100 element (Count Window)(sliding 
size : 10) and  also sum of 20 element(Count Window) (sliding size: 10) 
respectively. I realised that i have to calculate the both sum on 2 different 
stream respectively and so i did. Now i have 2 streams 1 containing the sum of 
100 element and the other one containing the sum of 20 element. Now i wanted to 
join the both datastream into 1 datastream. I'm using join and i realised that 
it can only supports Time Windows and Tumbling Window? Is there any other 
functions that i can use to solve my problem?


Example:

records:

date,price1,price2

date,price1,price2


sum to become:

date,sum_of_price1_for_100_element,sum_of_price2_for_20_element)

Reply via email to