Suppose that I have 2 different types of data streams, one providing weather data and the other providing vehicle data, and I would like to use Flink to do complex event processing on the data.
Which method in Flink 1.3.x is the correct method to use? I saw different methods like Union, Connect, Window Join. Basically I just want to try a simple CEP like this:
IF weather is wet AND vehicle speed > 60
WITHIN the last 10 seconds
THEN raise alert
Thanks!