How to assign windows dynamically after process() operator

hi all, I m trying to do a streaming process like below, 1. collect sensor events from a source 2. collect rule events defined for a device (which streams sensor events) 3. rules may have been defined with window information for aggregation processes differently for any device 4. when a

How to assign windows dynamically after process() operator

hi all, I m trying to do a streaming process like below, 1. collect sensor events from a source 2. collect rule events defined for a device (which streams sensor events) 3. rules may have been defined with window information for aggregation processes differently for any device 4. when a