Versions Compared

Old Version 35

changes.mady.by.user Wencong Liu

Saved on

compared with

New Version 36

changes.mady.by.user Wencong Liu

Saved on

Key

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

...

We define the PartitionWindowedStream as the result from transforming in a manner similar to of the transformation dataStream.window(EndOfStreamWindows.get()).  We add the fullWindowPartition method in DataStream class to replace the step of window(EndOfStreamWindows.get()) and return the PartitionWindowedStream in the method.

...