> The PR issued by Shunxin is based on the Windowed Operator and cannot be > used if you don't use Beam's windowing semantics. >
Can you explain a bit more how the windowed operator can be used? It would also be nice to see an example and documentation for this!
