Hi,
If I understood your problem correctly, you want to join two records, one
from each windowed stream.
You can do this by keying and connecting the two streams and apply a
stateful CoFlatMapFunction or CoProcessFunction to join them.
DataStream windowed1 = ...
DataStream windowed2 = ...
window
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
st
