Page History

...

The definition of PartitionWindowedStream

We define the PartitionWindowedStream as the result 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. first propose to add a new method fullWindowPartition() in DataStream class, which represents openning a full window on DataStream

The PartitionWindowedStream does not support setting the parallelism and has the same parallelism with previous operator.

...