Hi, In my scenario I have 2 streams. DS1 is main data stream reading logs from kafka, and DS2 is a parameter stream which is used to maintain a state about all processing parameters (including filters) need to be applied at runtime by DS1. The processing parameters can be changed anytime during the job is running.
DS1 is a windowed stream, DS2 is just a non-keyed normal stream. How to connect these 2 streams together so DS1 can apply those parameters in its window function by reading up-to-date parameter state maintained by DS2? thanks Lei
