Versions Compared

Old Version 47

changes.mady.by.user Wencong Liu

Saved on

compared with

New Version 48

changes.mady.by.user Wencong Liu

Saved on

Key

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

...

The definition of PartitionWindowedStream

To express the processing semantics of full window processing on DataStream, we need to define the corresponding method in DataStream class. One approach is to directly add a window(WindowAssigner assigner) method. This method only supports passing the EndOfStreamWindows introduced in FLIP-331. In the job code, if full window processing is desired, the corresponding code would be dataStream.window(EndOfStreamWindows.get()).

...