Versions Compared

Old Version 50

changes.mady.by.user Wencong Liu

Saved on

compared with

New Version 51

changes.mady.by.user Wencong Liu

Saved on

Key

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

...

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.

...