...
To avoid such issues, we propose defining a parameterless fullWindowPartition()
method on DataStream to express the semantics of full window processing. This method is functionally equivalent to the aforementioned dataStream.window(EndOfStreamWindows.get())
. By adopting this approach, users can explicitly apply full window processing without any misunderstandings.
...