Hi,

there are basically two operations to merge streams.

1. Union simply merges the input streams such that the resulting stream has the records of all input streams. Union is a built-in operator in the DataStream API. For that all streams must have the same data type.
2. Join connects records of streams according to a join condition. When joining streams, this condition is often based on some time bounds. Join usually needs to be manually implemented using a stateful CoProcessFunction.

Once the streams are unioned or joined, you can apply a time-window on the result stream.

Best, Fabian

2017-07-19 9:05 GMT+02:00 Jone Zhang <joyoungzhang@gmail.com>:
I have three data streams
1. app exposed and click
2. app download
3. app install

How can i merge the streams to create a unified stream,then compute it on time-based windows

Thanks