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