Versions Compared

Old Version 78

changes.mady.by.user Wencong Liu

Saved on

compared with

New Version 79

changes.mady.by.user Wencong Liu

Saved on

Key

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

...

Importantly, the DataSet API already offers full window processing capabilities. Integrating this existing capability of DataSet into DataStream would enhance its functionality and better meet the needs of users. Therefore, we propose to only support full window processing on DataStream.

...

Introduce the PartitionWindowedStream

To express the 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 to DataStream. This method only supports passing the EndOfStreamWindows introduced in FLIP-331. If users want to apply full window processing, the corresponding job code will bedataStream.window(EndOfStreamWindows.get()).

...