Versions Compared

Old Version 45

changes.mady.by.user Wencong Liu

Saved on

compared with

New Version 46

changes.mady.by.user Wencong Liu

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

However, this approach may lead users to mistakenly pass window assigners other than EndOfStreamWindows to the window(WindowAssigner assigner) method, which is not supported.

To avoid such issues, we propose defining a parameterless fullWindowPartition() method on DataStream to express the processing 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.

...