Hi,
right now, the Streaming Join only works on windows, so it would not work
for your case.
You can implement an approximation of this using connected streams, i.e.:
forecastedData.connect(realData).flatMap( new CoFlatMapFunction() );
the CoFlatMapFunction would receive the forecasts on the fir
Hi,
I’ve faced a problem trying to model our platform using Flink Streams.
Let me describe our model:
// Stream of data, ex. stocks: (AAPL, 100.0), (GZMP, 100.0) etc.
val realData: DataStream[(K, V)] = env.addSource(…)
// Stream of forecasts (same format) based on some window aggregates
val fo
